副本 策略 消息kafka
mongodb副本集(非仲裁模式)修改各节点ip(update方式)
环境:OS:Centos 7mongodb:5.0当前的ip 变更后的ip192.168.1.108 192.168.1.105 PRIMARY192.168.1.109 192.168.1.106 SECONDARY192.168.1.110 192.168.1.107 SECONDARY 1.查 ......
rabbitmq消息持久化
## 概念 消息是可以持久化保存的，持久的目的是为了处理任务丢失情况的，采用持久化可以保证消息存储，且消息不被丢失。 默认情况下 RabbitMQ 退出或由于某种原因崩溃时，它忽视队列 和消息，除非告知它不要这样做。确保消息不会丢失需要做两件事： **我们需要将队列和消息都标 记为持久化。** ## ......
模仿策略：在不确定的海洋中找到方向
## 引言：一场失利的帆船比赛 记得1986年的美洲杯帆船赛吗？美国队在领先的情况下，面临一个关于是否调整帆面的决策。结果，他们选错了，导致最后输掉了比赛。这场比赛后来成了博弈论（Game Theory）研究的一个经典案例。事实上，一个博弈论专家后来指出，如果美国队模仿澳大利亚队（当时处于第二名的位 ......
消息收发
消息收发 - IM 即时通讯（SDK） https://doc.yunxin.163.com/messaging/docs/jk0NDM1NjA?platform=android 历史消息 - IM 即时通讯（SDK） https://doc.yunxin.163.com/messaging/doc ......
RabbitMQ消息应答
# MQ中的消息应答 ## 前言 在消息队列当中，生产者发送消息给消费者，其中生产者通过中间件也就是rabbitmq将消息存储到此处，由消费者从mq中获取消息，并处理之后的逻辑，由于mq默认是采用自动应答机制，消费者在获取消息后就会通知mq，mq此时就会将消息内容删除，但是此时处理业务逻辑时发生了某 ......
mp之id雪花算法及其他主键策略
默认主键策略为ASSIGN_ID（全局唯一id） AUTO为自增id，需要在数据库中设置主键自增 NONE为不设置主键策略 INPUT将主键设置为手动输入 ASSIGN_UUID也是全局唯一id 实现步骤：在实体类中加入注解@TableId（type=IDType.AUTO）即可 ......
Kafka的分布式架构与高可用性
导语 一开始我们就说过Kafka是一款开源的高吞吐、分布式的消息队列系统，那么今天我们就来说下它的分布式架构和高可用性以及双/多中心部署。 Kafka 体系架构简介 以下是 Kafka 的软件架构，整个 Kafka 体系结构由 Producer、Consumer、Broker、ZooKeeper 组 ......
kafka配置内外网分流
骤修改kakfa配置文件config/server.properties 1、 修改listeners,这里配置本机kafka的监听地址 listeners=INSIDE://内网ip:9091,OUTSIDE://外网ip:9092 修改前 listeners= PLAINTEXT://10.12 ......
关于消息机制
异步消息通信在分布式系统中非常常见，它可以实现解耦、提高系统的可伸缩性和性能。以下是一些常见的异步消息通信的实例： 消息队列： 消息队列是一种常见的异步消息通信机制，用于在不同的应用或服务之间传递消息。一些流行的消息队列系统包括 Kafka、RabbitMQ、ActiveMQ、RocketMQ 等。 ......
【Kafka】kafka生产消费指令
### 推送kafka消息的指令： bin/kafka-console-producer.sh --broker-list 10.1.12.100:9092 --topic setPointValue 这个指令执行入，就会进入一个输入指令的状态，就是 光标变成 ">" 的状态 ### kafka消息 ......
103策略截图，期货量化用什么软件，TB交易开拓者
103策略研发3个月，适用国内期货， 选用10个品种对冲， 每个品种做1手， 占用保证金约5万5。 今日是第一次发贴 现在是2023年8月31日下午三点半了，星期四 如果你想咨询我，可以加我个人QQ：591438821， 今日盈利：1537元 下面的图片，是近月来的每日盈亏金额图 ......
Kafka - 生产者 - 压缩算法
总结 1.Producer 端压缩、Broker 端保持、Consumer 端解压缩。 2.开启压缩的最佳实践： Producer 端完成的压缩，那么启用压缩的一个条件就是 Producer 程序运行机器上的 CPU 资源要很充足。 如果你的环境中带宽资源有限，那么我也建议你开启压缩。如果你的机器 ......
简述Spring Cache缓存策略
### 一、简介 Spring框架提供了一种名为Spring Cache的缓存策略。Spring Cache是一种抽象层，它提供了一种方便的方式来管理缓存，并与Spring应用程序中的各种缓存实现（如EhCache、Guava、Caffeine等）集成。 Spring Cache使用注解（如@Cac ......
kafka安装部署与使用
##前言 ###1.kafka简介 Kafka是一个开源的分布式消息引擎/消息中间件，同时Kafka也是一个流处理平台。Kakfa支持以发布/订阅的方式在应用间传递消息，同时并基于消息功能添加了Kafka Connect、Kafka Streams以支持连接其他系统的数据(Elasticsearch ......
Kafka-基础
## 1. 简介 **Kafka（Apache Kafka）** 是一种分布式流数据平台，最初由LinkedIn开发，并于后来捐赠给Apache软件基金会，成为了一个Apache顶级项目。它被设计用于处理大规模、实时的数据流，并为构建高吞吐量、容错性强的数据流应用程序提供支持。Kafka的特点使得它 ......
数据库安全策略
对于以前项目的部分总结 应用在做二级等保时，会进行漏扫，安全扫描等 以下为数据库要求及解决方法 1、身份鉴别 要求用户口令需包含数字、大小写字母、特殊符号中的三种及三种以上，长度至少包含8位，并定期每季度更新口令。数据库口令复杂度策略未配置，口令未定期更换。可能导致创建出易被冒用的弱口令账户。可能导 ......
c# 使用webhook推送消息给钉钉机器人
c# 使用webhook推送消息给钉钉机器人 2023-08-04 08:31·opendotnet 在项目中将某个操作后的数据Webhook 发送给钉钉机器人。 Webhook 是一个 API 概念，是微服务 API 的使用范式之一，也被成为反向 API，即前端不主动发送请求，完全由后端推送；举个 ......
【Kafka3.0】消费者Consumer
[toc] ## kafak消费者 ### 消费者总体工作流程 - **kafka消费方式：**consumer采用从broker中主动拉取的方式去消费数据（pull）。为什么不是broker主动推送呢（push），是因为由broker决定发送速率很难适应所有消费者。pull模式的缺点是kafka没 ......
【kafka3.0】生产者producer
[toc] ## kafka生产者 ### 生产者消息发送流程 #### 发送原理 在消息发送的过程中，涉及到了两个线程——main 线程和 Sender 线程。在 main 线程中创建了一个双端队列 RecordAccumulator。main 线程将消息发送给 RecordAccumulat ......
钉钉消息已读、未读咋实现的嘞？
## 前言 一款app，消息页面有：钱包通知、最近访客等各种通知类别，每个类别可能有新的通知消息，实现已读、未读功能，包括多少个未读，这个是怎么实现的呢？比如用户A访问了用户B的主页，难道用rabitmq给B发通知消息吗？量大了成本受得了吗？有没有成本低的方案呢  # 背景 为了让业务团队可以更好的跟踪自己消息的生产和消费状态，需要一个类似于表格视图的消息列表，用户可以直观的看到发送的消息；同时点击详情后也能查到消息的整个 ......
【Apollo】【三】发布配置的过程-变更配置消息的发送与消费
1 前言 上节我们看了下发布配置的 Portal 以及 Admin Service的变化过程，我们看到Admin Service 的 messageSender.sendMessage()，发送消息以及消费消息，那么这节我们继续看。 2 MessageSender 发送消息 2.1 ReleaseM ......
Calico 网络策略
Calico 的网络策略 Calico支持GlobalNetworkPolicy和NetworkPolicy两种资源，前者用于定义集群全局网络策略，而后者大致可看作Kubernetes NetworkPolicy的一个超集。 Calico 网络策略提供了比 Kubernetes 更丰富的策略功能，包 ......
【Kafka3.0】broker、producer、consumer详解
# kafka3.0 [toc] ## 1. 什么是kafka？ - Kafka传 统定义：Kafka是一个分布式的基于发布/订阅模式的消息队列（MessageQueue），主要应用于大数据实时处理领域。 - Kafka最 新定义 ： Kafka是 一个开源的 分布式事件流平台 （Event Str ......
策略模式
# 策略模式 ## 1. 简介 策略模式`(Strategy Pattern)`允许在运行时选择算法或行为，从一组算法中选择一个合适的实现。这种模式使得算法的变化可以独立于使用算法的客户端。 策略模式的核心思想是将不同的算法封装成各自的`策略类`，然后在一个`上下文类`中维护一个策略接口的实例，根据 ......
MySQL到SelectDB的实时同步策略
MySQL 到 SelectDB 的实时数据同步技术，通过 NineData 的数据复制控制台，仅需轻点鼠标，即可轻松完成 MySQL 到 SelectDB 的同步任务配置。NineData 采用先进的数据同步技术，确保数据实时同步到 SelectDB，极大地降低了数据延迟，让您的决策基于最新数据。 ......