即实现单点发送消息,多点接收。使用fanout转发器,广播到所有它知道的队列上
fanout转发器中不需要routingKey,指定也无效
创建fanout转发器:
channel.exchangeDeclare("fanout_logs", "fanout");
channel.basicPublish("fanout_logs", "" , null, SerializationUtils.serialize(object));
临时队列的创建:
//创建一个临时队列,返回队列名称
String queueName=channel.queueDeclare().getQueue();
转发器与队列的绑定:
//绑定临时队列和转发器logs
channel.queueBind(queueName, "fanout_logs", "");
package com.demo.mq.rabbitmq.example03;
import java.io.IOException;
import java.io.Serializable;
import org.apache.commons.lang3.SerializationUtils;
import com.demo.mq.rabbitmq.MqManager;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
/**
* 发送消息类
* @author sheungxin
*
*/
public class Send{
/**
* 发送消息,fanout转发器,广播到所有在此转发器上的队列
* @param object 消息主体
* @throws IOException
*/
public static void sendAToB(Serializable object) throws Exception{
Connection conn=MqManager.newConnection();
Channel channel=conn.createChannel();
channel.exchangeDeclare("fanout_logs", "fanout");
channel.basicPublish("fanout_logs", "" , null, SerializationUtils.serialize(object));
System.out.println("A Send :'"+object+"'");
channel.close();
conn.close();
}
public static void main(String[] args) throws Exception {
for(int i=0;i<4;i++){
sendAToB("Hello World "+i+"!");
}
}
}
package com.demo.mq.rabbitmq.example03;
import java.io.IOException;
import org.apache.commons.lang3.SerializationUtils;
import com.demo.mq.rabbitmq.MqManager;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Consumer;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
/**
* 接收消息类
* @author sheungxin
*
*/
public class Recv {
/**
* 用于接收消息,创建一个临时队列,绑定在转发器fanout上
* @throws Exception
*/
public static void recvAToB() throws Exception{
Connection conn=MqManager.newConnection();
Channel channel=conn.createChannel();
channel.exchangeDeclare("fanout_logs", "fanout");
//创建一个临时队列
String queueName=channel.queueDeclare().getQueue();
//绑定临时队列和转发器logs
channel.queueBind(queueName, "fanout_logs", "");
Consumer consumer=new DefaultConsumer(channel){
@Override
public void handleDelivery(String consumerTag,Envelope envelope,AMQP.BasicProperties properties,byte[] body) throws IOException{
String mes=SerializationUtils.deserialize(body);
System.out.println("B Received :'"+mes+"'...");
}
};
//关闭自动应答机制,默认开启;这时候需要手动进行应该
channel.basicConsume(queueName, true, consumer);
}
public static void main(String[] args) throws Exception {
recvAToB();
}
}
分享到:
相关推荐
rabbitmq-practice:遵循RabbitMQ官方教程在python中练习代码:https://www.rabbitmq.comtutorialstutorial-one-python.html
RabbitMQ:安装、配置与使用初探
rabbitmq 发布/订阅 java 实现
vi etc/rabbitmq/rabbitmq.config 3、启动rabbitmq-server 运行rabbitmq: # ./sbin/rabbitmq-server 查看rabbitmq状态: # ./sbin/rabbitmqctl status 关闭rabbitmq: # ./sbin/rabbitmqctl stop 4、查看RabbitMQ服务...
适用于RabbitMQ的Docker 描述 该存储库使使用docker构建RabbitMQ变得简单。 先决条件 快速开始 docker-compose up -d ... - ./conf/:/etc/rabbitmq/ networks : - rabbitmq-net 步骤2:在端口中添加默认端口
RabbitMQ C AMQP客户端库简介这是C语言AMQP客户端库,可与RabbitMQ代理的v2.0 +一起使用。 http://github.com/alanxz/rabbitmq-c有关该库的声明是perio RabbitMQ C AMQP客户端库简介这是C语言AMQP客户端库,可与...
- RabbitMq-3.7.14(需安装rabbitmq_delayed_message_exchange延时消息插件) - 用到的框架: - SpringBoot-2.1.6 - MyBatis-3.4.6 - Shiro - [通用Mapper](https://github.com/abel533/Mapper "通用Mapper") -...
导入里面的sql,也就是一个user表,直接运行,访问http://localhost:8080/rabbitMq/getUserSyc/1同步调用mq 访问http://localhost:8080/rabbitMq/getUser/1异步调用mq 通过反射调用业务代码,实现一个队列可以多种...
该项目的目标是提供一种使用rabbitMQ的简便方法: 发布/订阅:pub套接字发布到一个集合点; 连接到集合点的所有子插座均会接收到消息。 发布/订阅持久:发布套接字到集合点; 连接到集合点的所有子套接字都通过自己...
WIP-Rabbitmq的Onyx插件。 安装 在这个阶段, git clone和lein install 。 然后在您的项目文件中: [onyx-rabbitmq " 0.7.0-SNAPSHOT " ] 职能 样本输入 目录条目: { :onyx/name :in :onyx/plugin :onyx.plugin....
在节点 161 中,将 `/var/lib/rabbitmq/.erlang.cookie` 文件复制到节点 230 的 `/var/lib/rabbitmq/.erlang.cookie`,并修改文件的属主与属性: ``` chown –hR rabbitmq .erlang.cookie chmod 400 .erlang.cookie ...
RabbitMQ示例3:发布与订阅【fanout转换器】 RabbitMQ示例4:路由【直接交换机】 RabbitMQ示例5:主题【topic切换】 RabbitMQ示例6:远程过程调用RPC Pom.xml <? xml version = " 1.0 " encoding = " UTF-8 ...
Sping Boot+Vue实现的前后端分离的管理系统,由微人事系统再开发而来。 通过leaflet+GIS实现3D地图的预览,包含人员管理 包含前后端代码以及数据库导入脚本,...指令:rabbitmq-plugins enable rabbitmq_management
rabbitmq spring rabbitmq spring rabbitmq spring rabbitmq spring http://knight-black-bob.iteye.com/blog/2304089
基于 SpringBoot+Maven+Mybatis+Redis+RabbitMQ 高并发商城秒杀系统; 开发工具IntelliJ IDEA 2017.3.1 x64; 项目搭建: 1、下载代码 将项目加载到IDEA里面 2、运行sql文件夹下的sql文件 3、到src/main/resources下...
springcloud bus rabbitmq 分布式队列 http://knight-black-bob.iteye.com/blog/2356839
安装与配置 RabbitMQ官方文档:https://www.rabbitmq.com/download.html其他参考:https://hub.docker
Windows安装RabbitMQ rabbitmq 3.8.2 安装教程 https://blog.csdn.net/tangcv/article/details/115747943
rabbitmq默认安装可视化管理插件,需要在CMD下启用rabbitmq-plugins enable rabbitmq_management 之后再依次执行如下命令重启服务器: rabbitmq-service.bat stop rabbitmq-service.bat start 执行完毕后。...
otp_win64_25.0.2 rabbitmq 3.10.2 安装步骤:https://blog.csdn.net/qq_36802726/article/details/125619207