副本 策略 消息kafka
MQ消息队列篇：三大MQ产品的必备面试种子题
MQ（Message Queue）作为一种用于实现异步通信的技术，具有重要的作用和应用场景。在面试过程中，MQ相关的问题经常被问到，因此了解MQ的用途和设计原则是必不可少的。本文总结了MQ的常见面试题，包括MQ的作用、产品选型、消息不丢失的保证、消息消费的幂等性、消息顺序的保证、消息的高效读写、分布... ......
go操作kafka
# go操作kafka 1. ZooKeeper是一个分布式协调服务，它的主要作用是为分布式系统提供一致性服务，提供的功能包括：配置维护、命名服务、分布式同步、组服务等。Kafka的运行依赖ZooKeeper。目前kafka3.2.0以上版本（[kafka_2.13-3.2.0.tgz](https ......
python发送消息到Teams以及阿里云的上传与删除
1 import urllib 2 import time 3 import oss2 4 import os 5 import random 6 from pathlib import Path 7 import requests 8 import datetime 9 from decouple ......
高并发三大法宝之 缓存，消息队列，异步任务
1.缓存（常用redis） 将热点数据或者经常需要进行read的数据放到redis或者其他缓存中，可以极大的降低数据库的压力，遇到流量高峰时，不至于一下子就把数据库压垮了，使用springcache配合redis继续使用，也可以很方便的对数据进行缓存。 springcache 几个常用注解 @Cac ......
iptables和firewalld开通策略日志
我的iptables中有这个规则： iptables -AINPUT -s 192.168.11.0/24 -j LOG 我的问题是： iptables日志文件在哪里，我该如何更改？ 这些日志由内核生成，因此它们将转到接收内核日志的文件： /var/log/kern.log 。 如果要将这些日志重定 ......
C#中Socket编程，异步实现Server端定时发送消息
在最近项目需求中，要求服务端定时向客服端发送消息。由于客户端从机的特性，只能接收Server发送的消息后回复，不能主动向服务端发送消息。 起初，并未使用异步的方法进行编程，使用了Accept()、Revice()等方法。由于从机不能主动发送消息的特性，并未考虑到从机断电不能接收到Server消息的情 ......
Redis中的过期策略
# redis过期策略 **定时过期、惰性过期、定期过期** 问题：使用expire key 60，在key60s之后key就会过期，之后如何清除key ## 定时过期 每个设置过期时间的key都创建一个定时器，到时间就会对key进行清除。该策略可以立即清除过期key，对内存友好，但是需要消耗大量的 ......
Kafka HW和LEO
[TOC] # 基本概念 ## LEO **LEO（log end offset）** 称为**日志末端位移**，代表日志文件中下一条待写入消息的 offset，这个 offset 上实际是没有消息的。 分区 ISR 集合中的每个副本（所有的 leader 和 follower 副本）都会维护自身的 ......
运行 docker-compose -f common.yml -f kafka_cluster.yml up 命令之后，其中一个broker容器未启动，原因是什么？
今天在运行 docker-compose -f common.yml -f kafka_cluster.yml up ，这条命令的时候，原来应该启动的broker-3容器没有启动，然后允许docker ps -a 查看存在但是没有up的容器。 找到broker-3的容器id:，docker logs ......
github学习笔记（九）：分支管理策略
> 合并的分支到底是如何管理的呢？ ## 分支的合并 通常git使用 Fast forward模式来合并分支，但是这种模式下一旦删除分支，信息也随之消失。如果强制禁用Fast Forward模式，git就会在merge时生成一个新分支，这样从分支历史上就可以看出分支信息。 ### 例子 创建并切换分 ......
执行Kafka Topic创建操作，发现Partition的Leader显示为none
问题背景与现象 在使用Kafka客户端命令创建Topic时，发现创建Topic Partition的Leader显示为none。 [root@10-10-144-2 client]# kafka-topics.sh --create --replication-factor 1 --partitio ......
第20章 基础系统设定与备份策略
## 第20章 基础系统设定与备份策略 ### 20.1 系统基本设定 #### 20.1.1 网络设定（手动设定与DHCP自动获得） 新的CentOS 7开始对于网卡的编号则有另一套规则，网卡的界面代号现在与网卡的来源有关\~基本上的网卡名称会是这样分类的： - eno1: 代表由主板BIOS内建 ......
判断evpp的发送消息是post 还是get
struct evhttp_request结构体定义了HTTP请求的各个字段，如请求行、请求头、请求正文等。 struct evhttp_request { int major; // 主版本号 int minor; // 次版本号 enum evhttp_cmd_type type; // 请求方 ......
redis做消息队列学习
转自：https://juejin.cn/post/7094272373930590245#heading-9，https://zhuanlan.zhihu.com/p/344269737 1、消息队列基本 作用：应用解耦（作为中介）、削峰填谷。redis做mq的优点：轻量级，使用和运维成本低。 m ......
在 SQL Server Always On 可用性组中的可用性副本之间同步登录
介绍 SQL Server Always On 可用性组为 SQL 数据库提供高可用性和灾难恢复解决方案。如果主副本出现任何问题，它会自动对辅助副本上的 AG 数据库进行故障转移。只要我们利用侦听器，您的应用程序就不需要对连接字符串进行任何更改。 但是，在 SQL Always On 中，同步可用性 ......
全局注册授权策略
1 using System; 2 using System.Security.Claims; 3 using System.Security.Principal; 4 using System.Threading.Tasks; 5 using Microsoft.AspNetCore.Authen ......
十九、消息查询
RocketMQ支持按照下面两种维度（“按照Message Id查询消息”、“按照Message Key查询消息”）进行消息查询。在RocketMQ dashboard中：  # ......
使用 AlwaysOn 可用性组只读辅助副本执行事务日志备份 - 第 1 部分
什么是日志序列号 (LSN)？ 在对 AlwaysOn 可用性组进行故障排除时，有多个 DMV 引用各种 LSN（日志序列号）。此外，备份和恢复操作经常引用并输出LSN值。 那么什么是LSN呢？LSN 是一个序列号，用于维护数据库内的顺序和跟踪操作。LSN 可以是十进制形式或十六进制形式，具体取决于 ......
Adobe InCopy 2023 v18.3 (macOS, Windows) - 编写和副本编辑软件
Adobe InCopy 2023 v18.3 (macOS, Windows) - 编写和副本编辑软件 Acrobat、After Effects、Animate、Audition、Bridge、Character Animator、Dimension、Dreamweaver、Illustrato ......
asp.net core 2.0 web api基于JWT自定义策略授权
原文 通过登录，来获取Token，再在之后每次请求的Header中追加Authorization为Token的凭据，服务端验证通过即可能获取想要访问的资源。关于JWT的技术，可参考网络上文章，这里不作详细说明， 这篇博文，主要说明在asp.net core 2.0中，基于jwt的web api的权限 ......
AlwaysOn添加新可用性副本
一、前期调研工作 1.1 数据库版本及组件 版本查询 DECLARE @Version NVARCHAR(128) SET @Version = CONVERT(NVARCHAR(128),SERVERPROPERTY ('ProductVersion'))SELECT CASE WHEN @Ver ......
Kafka
Kafka是一种高吞吐量的分布式发布订阅消息系统 Kafka 遵循了传统的方式，选择由 Producer 向 broker push 消息并由 Consumer 从 broker pull 消息 Producer：Producer即生产者，消息的产生者，是消息的入口。 Broker：Broker是k ......
微信公众号模板消息源码实现，打破服务号群发推送次数限制
公众号服务号每个月只能群发推送四次文章，我们可以使用模板消息为公众号粉丝推送信息 下面是使用golang实现的模板消息发送类库封装，轻松实现模板消息发送 wechat.go package lib import ( "github.com/silenceper/wechat/v2" "github. ......
策略模式+Spring配置类优化多if..else思路
## 图示  ## 1. 现状 > 场景: 假设设备上报不同类型的消息，我们要对不同类型的消息做不同的处理 ......
ASP.NET Core-授权-自定义策略
一 、什么是基于策略的授权基于策略的授权是 ASP.NET Core 中引入的一种新的授权方法。一个授权策略由一个或者多个 requirement 构成。 二 、添加策略在 Startup 中添加策略： services.AddAuthorization(options =>{ // 自定义策略授权 ......