生产者：生产者是负责发送消息的 队列：队列是RabbitMQ用来存储消息的，受主机内存和磁盘大小的限制，本质上是一个消息的缓冲区。生产者可以将消息发送至队列中，消费者可以从队列中接收到消息 消费者：消费者是用来等待接收消息 生产者，消费者，代理可以驻留在不同主机或同一主机，一个应用可以是生产者也可以 ...
分类：
其他好文 时间：
2020-02-12 11:15:35
阅读次数：
77
背景导入 让我们来看一下这个场景： 你有一个温度传感器，它每三个小时向一个 Topic 发布当前的温度。那么问题来了，有一个新的订阅者在它刚刚发布了当前温度之后订阅了这个主题，那么这个订阅端什么时候能才能收到温度消息？ 对的，它必须等到三个小时以后，温度传感器再次发布消息的时候才能收到。在这之前，这 ...
分类：
其他好文 时间：
2020-02-05 12:00:03
阅读次数：
391
RabbitMQ简介 MQ全称为Message Queue，即消息队列，RabbitMQ使用Erlang语言开发。 它基于AMQP协议（Advanced Message Queue高级消息队列协议）实现的消息队列。 它是一种应用程序之间通信的方式，在分布式系统中应用十分广泛。 应用场景 1、任务异步 ...
分类：
其他好文 时间：
2020-01-31 18:41:50
阅读次数：
87
在之前的文章 "RabbitMQ入门（二）工作队列" 中，我们创建了一个工作队列。工作队列背后的假设是每一项任务都被准确地传送至一个worker。在本文中，我们将会做一些不同的事情——我们将会把一个消息发送至许多消费者中。这种模式被称为 。 为了解释这种模式，我们将会构建一个简单的日志系统。它包含两 ...
分类：
其他好文 时间：
2020-01-28 16:00:48
阅读次数：
77
消息服务 背景：有时需与其它系统集成来完成相关业务功能，原始的做法是程序内部相互调用，除此之外，还可用消息服务中间件来进行业务处理，使用消息服务中间件处理业务能够提升系统的异步通信和扩展解耦的能力，个人有点面向切面的意思。 一.为什么要使用消息服务？ 因为它有很多好处，能解决很多问题； 1.异步处理 ...
分类：
编程语言 时间：
2020-01-26 13:17:33
阅读次数：
94
前言 第二次发博客，希望大家多多鼓励！！！ 又接无上老板的一个需求，需要让.net core消息发送端跟消息接收端通信的消息是protobuf格式的（基于protobuf比json小一倍数据量，独特的编码、没有fieldname等），但现有项目的消息类数量巨多，按照网上的方案是安装protobuf. ...
分类：
Web程序 时间：
2020-01-22 12:35:57
阅读次数：
91
如果不清楚本篇内容的，请务必先去看完上一篇再看本篇，否则阅读起来可能会有部分障碍和困难； 上一篇文章《SpringCloud学习之Stream消息驱动【默认通道】（十）》我们简单用自定义通道实现了消息发送和接收，但是用的是Stream给我们提供的默认Source，Sink，接下来我们要自己进行自定义 ...
分类：
编程语言 时间：
2020-01-18 18:06:41
阅读次数：
193
微信公众号：一个优秀的废人。如有问题，请后台留言，反正我也不会听。 前言 昨天那篇介绍了 WebSocket 实现广播，也即服务器端有消息时，将消息发送给所有连接了当前 endpoint 的浏览器。但这无法解决消息由谁发送，又由谁接收的问题。所以，今天写一篇实现一对一的聊天室。 今天这一篇建立在昨天 ...
分类：
编程语言 时间：
2020-01-17 13:23:48
阅读次数：
91
comitlog文件 ConsumerQueue文件 IndexFile文件 RocketMQ将所有主题的消息存储在同一个文件中，确保消息发送时顺序写文件。 为了提高消息消费的效率RocketMQ引入了ConsumeQueue消息队列文件，每个消息主题包含一个多个消息消费队列，每一个消费队列有一个消 ...
分类：
其他好文 时间：
2020-01-17 09:16:40
阅读次数：
110
RemotingCommand: flag倒数第一位表示请求类型，0请求1返回。倒数第二位1.表示oneway 单条消息发送时，消息体的内容将保存在body种，批量消息发送，需要将多条消息体的内容存储在body中，RocketMQ采取的方式是，对单条消息内容使用固定格式进行存储 ...
分类：
其他好文 时间：
2020-01-17 00:15:26
阅读次数：
90
