准备工作：composer 引入 php-amqplib 说明：本文说明基于 Java（主要说明原理），实现使用 php RabbitMQ Java 客户端使用 com.rabbitmq.client 作为顶级包名，关键的 Class 和 Interface 有 Cahnnel、Connection ...
分类：
其他好文 时间：
2019-01-28 00:59:31
阅读次数：
199
事务消息主要用在发送方 因为发送方 发出消息后，不能确定broker一定收到了 所以在connection上加上事务属性， 发送方感知到发送失败，可以做其他处理（比如先在数据库记上一笔，后面补发此消息） ...
分类：
其他好文 时间：
2019-01-28 00:51:53
阅读次数：
177
我们知道无论是生产者还是消费者，都需要和 RabbitMQ Broker 建立连接，这个连接就是一条 TCP 连接，也就是 Connection。 一旦 TCP 连接建立起来，客户端紧接着可以创建一个 AMQP 信道（Channel），每个信道都会被指派一个唯一的 ID。 信道是建立在 Connec ...
分类：
其他好文 时间：
2019-01-27 19:26:01
阅读次数：
772
RabbitMQ 整体上是一个生产者与消费者模型，主要负责接收、存储和转发消息。可以把消息传递的过程想象成：当你讲一个包裹送到邮局，邮局会暂存并最终将邮件通过邮递员送到收件人的手上，RabbitMQ 就好比由邮局、邮箱和邮递员组成的一个系统。从计算机术语层面来说，RabbitMQ 模型更像是一种交换 ...
分类：
其他好文 时间：
2019-01-27 19:21:38
阅读次数：
173
生产者发送消息 1、生产者连接到 RabbitMQ Broker，建立一个连接（Connection），开启一个信道（Channel） 2、生产者声明一个交换器，并设置相关属性，比如交换机类型、是否持久化等 3、生产者声明一个队列并设置相关属性，比如是否排他、是否持久化、是否自动删除等 4、生产者通 ...
分类：
其他好文 时间：
2019-01-27 19:18:54
阅读次数：
180
在发送小消息的场景中,三个消息中间件的表现区分明显: Kafka的吞吐量高达17.3w/s,远超其他两个产品。这主要取决于它的队列模式保证了写磁盘的过程是线性IO。此时broker磁盘IO已达瓶颈。 RocketMQ也表现不俗,吞吐量在11.6w/s,磁盘IO %util已接近100%。Rocket ...
分类：
其他好文 时间：
2019-01-26 22:38:02
阅读次数：
245
1.引言 RabbitMQ——Rabbit Message Queue的简写，但不能仅仅理解其为消息队列，消息代理更合适。RabbitMQ 是一个由 Erlang 语言开发的AMQP（高级消息队列协议）的开源实现，其内部结构如下： RabbitMQ作为一个消息代理，主要和消息打交道，负责接收并转发消 ...
分类：
其他好文 时间：
2019-01-26 20:23:50
阅读次数：
178
MQ的流行度跟它的特性和应用场景密切相关，站在当下来看，kafka最火，rabbitmq用的也很多，ActiveMQ作为经典mq选择用它入门的也不少。 ...
分类：
其他好文 时间：
2019-01-25 11:36:13
阅读次数：
127
[环境：centos 7] ##下在erlang安装包wget https://packages.erlang-solutions.com/erlang-solutions-1.0-1.noarch.rpm rpm -Uvh erlang-solutions-1.0-1.noarch.rpm##下载 ...
分类：
其他好文 时间：
2019-01-25 11:30:24
阅读次数：
145
1.jar包依赖 2.application.properties配置文件 3.queue模式 <1>.一对一的字符串的简单传输 1).队列配置 2).发送者 3).接受者 4).测试 <2>.一对多和多对多传输 1).在配置队列中添加配置 2).发送者 3).接受者 4).测试 <3>.传输对象和 ...
分类：
编程语言 时间：
2019-01-24 17:26:42
阅读次数：
119
