php mq订阅2个消息,用rabbitMQ实现消息的发布和订阅

ゝ一世哀愁。 2023-01-17 10:52 116阅读 0赞

RabbitMQ可以实现消息发布和订阅，这其中需要exchange，消息的发布者，消费者，消息队列和Exchange关系如下图

![1401018ba7953a9d5f7016c9f6c3d5be.png][]

消息的生产者发出消息，然后经过Exchange转换，消息队列(queue)需要绑定Exchange，Exchange把消息发送到各个消息队列中，然后，各个消费者从消息队列中取到发布者发布的消息。

利用Java作为客户端，具体代码如下：

发布者代码

import com.rabbitmq.client.Channel;

import com.rabbitmq.client.Connection;

import com.rabbitmq.client.ConnectionFactory;

/\*\*

\*

\* 用rabbitMQ实现发布订阅

\* 发布类

\* Created by wangtf on 2015/11/17.

\*/

public class Emitlog \{

private static final String EXCHANGE\_NAME = "logs";

public  static  void main(String args\[\]) throws  Exception\{

ConnectionFactory connectionFactory = new ConnectionFactory();

connectionFactory.setHost("localhost");

Connection connection = connectionFactory.newConnection();

Channel channel = connection.createChannel();

channel.exchangeDeclare(EXCHANGE\_NAME,"fanout");

String msg = "各单位请注意";

channel.basicPublish(EXCHANGE\_NAME,"",null,msg.getBytes());

System.out.println("\[send\] msg: " +msg);

channel.close();

connection.close();

\}

\}

消息接受类

import com.rabbitmq.client.\*;

import java.io.IOException;

/\*\*

\* RabbitMQ实现发布订阅的功能

\* 订阅类

\* Created by wangtf on 2015/11/17.

\*/

public class ReceiveLogs \{

private static final String EXCHANGE\_NAME = "logs";

public static void main(String\[\] args) throws  Exception\{

ConnectionFactory factory = new ConnectionFactory();

factory.setHost("localhost");

Connection connection = factory.newConnection();

Channel channel = connection.createChannel();

channel.exchangeDeclare(EXCHANGE\_NAME,"fanout");

String queueName = channel.queueDeclare().getQueue();

channel.queueBind(queueName,EXCHANGE\_NAME,"");

System.out.print("\[\*\] waiting for message");

DefaultConsumer consume = new DefaultConsumer(channel)\{

@Override

public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte\[\] body) throws IOException \{

String message = new String(body,"UTF-8");

System.out.println("\[x\] receive message :" + message);

\}

\};

channel.basicConsume(queueName,true,consume);

\}

\}

分别运行ReceiveLogs和Emitlog，能得到如下结果：

【Emitlog】

\[send\] msg: 各单位请注意

Process finished with exit code 0

【ReceiveLogs】

\[\*\] waiting for message\[x\] receive message :各单位请注意

[1401018ba7953a9d5f7016c9f6c3d5be.png]: /images/20221021/5a1581475a28473ba969230734e639d0.png

发表评论取消回复

表情：

评论列表（有 0 条评论，116人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ：订阅模型-消息订阅模式

> 订阅模型-消息订阅模式，也可以称为广播模式，生产者将消息发送到 Exchange，Exchange 再转发到与之绑定的 Queue中，每个消费者再到自己的 Queue 中取

淡淡的烟草味﹌/ 2023年09月23日 20:12/ 0 赞/ 49 阅读

相关 php mq订阅2个消息,用rabbitMQ实现消息的发布和订阅

RabbitMQ可以实现消息发布和订阅，这其中需要exchange，消息的发布者，消费者，消息队列和Exchange关系如下图 ![1401018ba7953a9d5f701

ゝ一世哀愁。/ 2023年01月17日 10:52/ 0 赞/ 117 阅读

相关 redis的消息发布和订阅

publish news（消息名称） something（消息内容）发布一条消息 subscribe news 订阅消息 psubscribe pattern 订阅符合pa

小咪咪/ 2022年10月31日 13:34/ 0 赞/ 205 阅读

相关 Redis消息订阅发布

Redis 消息订阅发布一、是什么进程间的一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。二、命令 <table> <the

﹏ヽ暗。殇╰゛Y/ 2022年09月26日 14:56/ 0 赞/ 180 阅读

相关 redis消息订阅和发布实例

发布订阅(pub/sub)是一种消息通信模式，主要目的是解除消息发布者、消息订阅者之间的耦合 pub/sub的特点 1、发布者和订阅者不必同时在线，它们不必同时参与交互

秒速五厘米/ 2022年07月19日 00:18/ 0 赞/ 217 阅读

相关 redis发布订阅消息

一、Redis服务器端的安装和客户端Jedis的安装 1.下载Redis 下载地址：[http://redis.googlecode.com/files/redis-

「爱情、让人受尽委屈。」/ 2022年06月09日 00:56/ 0 赞/ 283 阅读

相关 EMP 实现消息发布订阅

官网文档 [http://emqtt.com/docs/v2/index.html][http_emqtt.com_docs_v2_index.html] php 实

深碍√TFBOYSˉ_/ 2022年05月04日 15:28/ 0 赞/ 206 阅读

相关 redis消息订阅发布

进程间的一种消息通信模式：发送者(pub)发送消息，订阅者(sub)接收消息。 ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdG

本是古典何须时尚/ 2022年02月02日 16:51/ 0 赞/ 283 阅读

相关消息订阅

使用办法: 订阅端: Subscribe 频道名称发布端: publish 频道名称发布内容客户端例子: redis 127.0.0.1:6379> sub

我不是女神ヾ/ 2022年01月10日 11:25/ 0 赞/ 228 阅读

相关 redis消息的订阅和发布

Pub/Sub redis的消息的订阅和发布，类似与生产者和消费者模式，可以一对一，也能一对多。客户端可以选择订阅的消息：通过命令 subscribe boo //

桃扇骨/ 2022年01月07日 07:55/ 0 赞/ 271 阅读