RocketMQ主从搭建 部署环境 作为测试环境，我们使用两台虚拟机来部署双主双从环境，具体结构如下： 整个集群由两个 name server 实例和四个 broker 实例组成 name server: 两台服务器分别启动两个name server broker A 主从: 服务器1部署 brok ...
分类：
其他好文 时间：
2020-09-24 21:11:19
阅读次数：
42
RocketMQ基本原理 Topic 基本原理 在Rocketmq集群中新建 Topic1 在管理界面中新建主题Topic1，为了方便观察测试效果，这里把写队列和读队列的数量都设置成3。 这样，在 broker-a 和 broker-b 上都创建了 Topic1 主题，并各创建了3写3读队列，共6写 ...
分类：
其他好文 时间：
2020-09-24 21:09:22
阅读次数：
42
一、消息的事务性 1、生产者 01、生产者不开启事务 不开启事务的生产代码: public class JmsQueueProducer { public static final String BROKER_URL = "tcp://192.168.229.129:61616"; public s ...
分类：
其他好文 时间：
2020-09-24 00:03:28
阅读次数：
36
Kafka是Apache下的一个子项目，是一个高性能跨语言分布式发布/订阅消息队列系统，吞吐速率非常快，可以作为Hadoop的日志收集。Kafka是一个完全的分布式系统，这一点依赖于Zookeeper的分布式实现。 本文为新手准备，从Kafka的一些术语概念方面去认识Kafka。 Broker Ka ...
分类：
其他好文 时间：
2020-09-18 17:19:41
阅读次数：
37
算符优先文法的应用 #include<iostream> using namespace std; const int N = 110; char sb[N], pp = -1; int dg[N], qq = -1; int cmp(char a, char b){ if(a == '(') re ...
分类：
其他好文 时间：
2020-09-18 02:55:39
阅读次数：
31
1.概念 CASB：云访问安全代理 Cloud Access Security Broker 最早是为解决影子资产问题，尤其是随着SaaS服务的快速发展。CASB核心价值是解决深度可视化、 数据安全、威胁防护、合规性这四类问题 CSPM：云安全配置管理 Cloud Security Posture ...
分类：
其他好文 时间：
2020-09-18 00:51:10
阅读次数：
30
CSDN：程序员小羊 微信公众号：程序员小羊 1、Kafka 是什么 Kafka 是一种高吞吐量、分布式、基于发布/订阅的消息系统，最初由 LinkedIn 公司开发，使用Scala 语言编写，目前是 Apache 的开源项目。 broker： Kafka 服务器，负责消息存储和转发 topic：消 ...
分类：
其他好文 时间：
2020-09-17 21:42:29
阅读次数：
32
1.kafka是一个分布式的消息队列，缓存系统，消息的发布和订阅系统。 2.始于Linkedin公司，开源于apache。 3.包含生产者，消费者，broker。 4.每秒支持百万消息处理。 5.支持多个生成者，多个消费者，多个broker 6.生成者产生数据，按topic分类数据，对数据进行分区， ...
分类：
其他好文 时间：
2020-09-17 13:42:05
阅读次数：
36
最近看了@JavaGuide发布的一篇『面试官问我如何保证Kafka不丢失消息?我哭了！』，这篇文章承接这个主题，来聊聊如何保证RocketMQ不丢失消息。0x00.消息的发送流程一条消息从生产到被消费，将会经历三个阶段：生产阶段，Producer新建消息，然后通过网络将消息投递给MQBroker存储阶段，消息将会存储在Broker端磁盘中消息阶段，Consumer将会从Broker拉取消息以上任
分类：
其他好文 时间：
2020-08-05 18:15:11
阅读次数：
81
