搜索结果
查询Tags标签： Broker，共有 150条记录-
双主双从集群搭建示例
1、总体架构介绍 下面我们搭建一个双主双从的集群，并且采用同步的方式来同步主从之间的信息，总体架构如下： 2、集群工作流程 集群工作流程如下：启动NameServer，NameServer起来后监听端口，等待Broker、Producer、Consumer连上来，相当于一个路由控制中心。 Broker启…
2021/12/19 6:20:36 人评论 次浏览 -
双主双从集群搭建示例
1、总体架构介绍 下面我们搭建一个双主双从的集群，并且采用同步的方式来同步主从之间的信息，总体架构如下： 2、集群工作流程 集群工作流程如下：启动NameServer，NameServer起来后监听端口，等待Broker、Producer、Consumer连上来，相当于一个路由控制中心。 Broker启…
2021/12/19 6:20:36 人评论 次浏览 -
EMQX Broker性能测试
1、工具安装 使用yum进行安装 yum install -y yum-utils device manager-persistent-data lvm2 yum-config-manager --add-repo https://repos.emqx.io/emqx-ce/redhat/centos/7/emqx-ce.repo yum install emqx-4.3.5常用命令 启动：systmctl start emqx.service 状态：sy…
2021/12/18 23:23:52 人评论 次浏览 -
EMQX Broker性能测试
1、工具安装 使用yum进行安装 yum install -y yum-utils device manager-persistent-data lvm2 yum-config-manager --add-repo https://repos.emqx.io/emqx-ce/redhat/centos/7/emqx-ce.repo yum install emqx-4.3.5常用命令 启动：systmctl start emqx.service 状态：sy…
2021/12/18 23:23:52 人评论 次浏览 -
编程中的观察者模式和发布订阅模式
一.观察者模式 所谓观察者模式，其实就是为了实现松耦合(loosely coupled)。 用《Head First 设计模式》里的气象站为例子，每当气象测量数据有更新，changed() 方法就会被调用，于是我们可以在 changed() 方法里面，更新气象仪器上的数据，比如温度、气压等等。 但是这样…
2021/12/9 17:20:24 人评论 次浏览 -
编程中的观察者模式和发布订阅模式
一.观察者模式 所谓观察者模式，其实就是为了实现松耦合(loosely coupled)。 用《Head First 设计模式》里的气象站为例子，每当气象测量数据有更新，changed() 方法就会被调用，于是我们可以在 changed() 方法里面，更新气象仪器上的数据，比如温度、气压等等。 但是这样…
2021/12/9 17:20:24 人评论 次浏览 -
kafka 学习笔记1
Event streaming is the digital equivalent of the human body’s central nervous system概述 分布式基于发布/订阅模式的消息队列，应用于大数据实时处理领域。 1 6 3005 应用 异步处理 两种模式 点对点 消费者主动拉取消息发布订阅 一对多 消费者消费数据后不会清除消…
2021/12/1 23:10:05 人评论 次浏览 -
kafka 学习笔记1
Event streaming is the digital equivalent of the human body’s central nervous system概述 分布式基于发布/订阅模式的消息队列，应用于大数据实时处理领域。 1 6 3005 应用 异步处理 两种模式 点对点 消费者主动拉取消息发布订阅 一对多 消费者消费数据后不会清除消…
2021/12/1 23:10:05 人评论 次浏览 -
RocketMQ高阶业务问题及解决方案
RocketMq全链路消息零丢失方案 发送消息到mq零丢失: 事务消息Broker 存储消息零丢失：同步刷盘+主从机制Consumer 消费消息零丢失：手动提交offset + 自动故障转移 Broker消息零丢失方案：同步刷盘 + Raft协议主从同步 Broker 是负责存储消息的，怎么保证消息发送到Broker…
2021/11/29 23:36:25 人评论 次浏览 -
RocketMQ高阶业务问题及解决方案
RocketMq全链路消息零丢失方案 发送消息到mq零丢失: 事务消息Broker 存储消息零丢失：同步刷盘+主从机制Consumer 消费消息零丢失：手动提交offset + 自动故障转移 Broker消息零丢失方案：同步刷盘 + Raft协议主从同步 Broker 是负责存储消息的，怎么保证消息发送到Broker…
2021/11/29 23:36:25 人评论 次浏览 -
高并发异步解耦利器：RocketMQ究竟强在哪里？
上篇文章消息队列那么多，为什么建议深入了解下RabbitMQ？我们讲到了消息队列的发展史：并且详细介绍了RabbitMQ，其功能也是挺强大的，那么，为啥又要搞一个RocketMQ出来呢？是重复造轮子吗？本文我们就带大家来详细探讨RocketMQ究竟好在哪里。 RocketMQ是一个分布式消息…
2021/11/22 23:11:05 人评论 次浏览 -
高并发异步解耦利器：RocketMQ究竟强在哪里？
上篇文章消息队列那么多，为什么建议深入了解下RabbitMQ？我们讲到了消息队列的发展史：并且详细介绍了RabbitMQ，其功能也是挺强大的，那么，为啥又要搞一个RocketMQ出来呢？是重复造轮子吗？本文我们就带大家来详细探讨RocketMQ究竟好在哪里。 RocketMQ是一个分布式消息…
2021/11/22 23:11:05 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
kafka、rabbitmq、redis区别，各自适合什么场景？
转载kafka、rabbitmq、redis区别，各自适合什么场景？ - Kris-Q - 博客园 在应用场景方面RabbitMQ RabbitMQ遵循AMQP协议，由内在高并发的erlanng语言开发，用在实时的对可靠性要求比较高的消息传递上，适合企业级的消息发送订阅，也是比较受到大家欢迎的。kafka kafka是L…
2021/11/21 2:12:07 人评论 次浏览 -
如何在linux上安装RocketMQ
在linux上安装RocketMQ 一、上传安装包二、解压安装包三、配置环境变量四、修改配置修改启动脚本JVM参数修改namesrv启动脚本内存参数修改broker启动脚本内存参数五、启动服务与测试启动nameserver启动broker发送消息关闭nameserver关闭Broker 六、单节点远程配置基本配置…
2021/11/18 7:12:04 人评论 次浏览
