介绍 一种高吞吐量的分布式发布订阅消息系统 消息类型：主体Topic（广播）、队列Queue（一对一） 消息系统类型：同步消息系统、异步消息系统 常见消息产品：Redis、Kafka、JMS 术语 Topic：Kafka处理消息源（feeds of messages）的不同分类（不同于传统MQ） P ...
分类：
数据库 时间：
2020-06-18 21:34:03
阅读次数：
82
一、环境准备 1.主机信息 主机名 主机IP地址 备注 broker-k8s-1 192.168.144.131 master &namesrv broker-k8s-2 192.168.144.132 master &namesrv broker-k8s-3 192.168.144.133 mas ...
分类：
其他好文 时间：
2020-06-17 09:14:59
阅读次数：
49
前言： RocketMq producer 在发送一条消息时候，从 producer --nameSrv -- Broker 中间经过了什么样子的数据交互 开始： 如下是 Producer 发送消息的一个demo例子： //1. 初始化 mq producer DefaultMQProducer m ...
分类：
其他好文 时间：
2020-06-17 01:03:26
阅读次数：
87
概述 大多应用中, 可以通过消息服务中间件来提升系统异步通信, 扩展解耦能力. 消息服务中的两个重要概念 消息代理(message broker)和目的地(destination) 当消息发送者发送消息时, 由消息代理接管, 消息代理保证消息传递到指定目的地. 消息队列主要有两种形式的目的地 队列( ...
分类：
编程语言 时间：
2020-06-16 16:56:50
阅读次数：
63
作者：一号线 https://segmentfault.com/a/1190000022387211 RabbitMQ是基于AMQP协议的，通过使用通用协议就可以做到在不同语言之间传递。 AMQP协议 核心概念 server：又称broker，接受客户端连接，实现AMQP实体服务。 connecti ...
分类：
其他好文 时间：
2020-06-16 16:48:15
阅读次数：
47
默认方式：先入先出，消息被追加写入每个分区的尾部 分区：可以在不同的服务器上，也就是说，一个主题可以横跨多个服务器 我们吧一个主题的数据看成一个流，不管分多少区，流就是一组从生产者移动到消费者 一个kafka服务器被称为broker，一个broker可以轻松处理数千个分区一级美妙百万级的消息量 保留 ...
分类：
其他好文 时间：
2020-06-15 10:14:47
阅读次数：
57
昨日回顾: 1 什么是celery:执行异步任务,和定时任务 -架构 -broker:消息中间人,redis,rabbitmq -worker:执行者(开多个) -backend:结果存储,redis -异步任务: 提交任务到broker中: -函数.delay(参数) -函数.apply_asyn ...
分类：
其他好文 时间：
2020-06-14 12:44:03
阅读次数：
62
前言： 要了解rocketMq 需要知道 数据在 rocketMq 中 是如何进行传输，在底层的结构到底是一个什么亚子，这个需要我们对Netty 对字符编解码有一些了解。 开始： 我们从生产者发送消息，broker 接收消息 为例，来开展底层对消息结构。 1. 如下是一段生产者发送消息的代码，这里我 ...
分类：
Web程序 时间：
2020-06-13 23:10:22
阅读次数：
78
rocketmq-all-4.2.0：https://niceyoo.lanzous.com/iZRz9dj15sb 百度云链接：https://pan.baidu.com/s/1u3zAZgynOH91vv2_5KjI0Q 密码:8zrp 1、配置环境变量 下载解压后配置一下系统RocketMQ环 ...
ActiveMQ作为消息队列Queue以及Topic主题订阅模式的Broker，在我们使用Windows开发环境时，需要如下配置 1 下载Jdk 略 此处作为开发人员jdk环境是比不可好的，所以jdk配置不再赘述，运行ActiveMQ是需要jdk支持的 2 下载ActiveMQ，地址如下： http ...
