（转）RabbitMQ学习之路由（java）

http://blog.csdn.net/zhu_tianwei/article/details/40887755

参考：http://blog.csdn.NET/lmj623565791/article/details/37669573

使用direct类型实现：消息会被推送至绑定键（binding key）和消息发布附带的选择键（routing key）完全匹配的队列。例如：将不同的日志发送到不同的消费端。

1.发送日志端SendLogDirect.Java

[java] view plaincopy print?

package cn.slimsmart.rabbitmq.demo.route;
import java.util.Random;
import java.util.UUID;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
//随机发送6条随机类型（routing key）的日志给转发器~~
public class SendLogDirect {
//交换名称
private static final String EXCHANGE_NAME = "ex_logs_direct";
//日志分类
private static final String[] SEVERITIES = { "info", "warning", "error" };
public static void main(String[] args) throws Exception {
//创建连接和频道
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.101.174");
// 指定用户密码
factory.setUsername("admin");
factory.setPassword("admin");
// 指定端口
factory.setPort(AMQP.PROTOCOL.PORT);
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
// 声明转发器的类型
channel.exchangeDeclare(EXCHANGE_NAME, "direct");
//发送6条消息
for (int i = 0; i < 6; i++)
{
String severity = getSeverity();
String message = severity + "_log :" + UUID.randomUUID().toString();
// 发布消息至转发器，指定routingkey
channel.basicPublish(EXCHANGE_NAME, severity, null, message .getBytes());
System.out.println(" [x] Sent '" + message + "'");
}
channel.close();
connection.close();
}
/**
* 随机产生一种日志类型
*
* @return
*/
private static String getSeverity()
{
Random random = new Random();
int ranVal = random.nextInt(3);
return SEVERITIES[ranVal];
}
}

2.接收日志端ReceiveLogsDirect.java

[java] view plaincopy print?

package cn.slimsmart.rabbitmq.demo.route;
import java.util.Random;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;
//接收端随机设置一个日志严重级别（binding_key）。。。
public class ReceiveLogsDirect {
private static final String EXCHANGE_NAME = "ex_logs_direct";
private static final String[] SEVERITIES = { "info", "warning", "error" };
public static void main(String[] args) throws Exception {
// 创建连接和频道
ConnectionFactory factory = new ConnectionFactory();
factory.setHost("192.168.101.174");
// 指定用户密码
factory.setUsername("admin");
factory.setPassword("admin");
// 指定端口
factory.setPort(AMQP.PROTOCOL.PORT);
Connection connection = factory.newConnection();
Channel channel = connection.createChannel();
// 声明direct类型转发器
channel.exchangeDeclare(EXCHANGE_NAME, "direct");
String queueName = channel.queueDeclare().getQueue();
String severity = getSeverity();
// 指定binding_key
channel.queueBind(queueName, EXCHANGE_NAME, severity);
System.out.println(" [*] Waiting for "+severity+" logs. To exit press CTRL+C");
QueueingConsumer consumer = new QueueingConsumer(channel);
channel.basicConsume(queueName, true, consumer);
while (true)
{
QueueingConsumer.Delivery delivery = consumer.nextDelivery();
String message = new String(delivery.getBody());
System.out.println(" [x] Received '" + message + "'");
}
}
/**
* 随机产生一种日志类型
*
* @return
*/
private static String getSeverity()
{
Random random = new Random();
int ranVal = random.nextInt(3);
return SEVERITIES[ranVal];
}
}

启动几个接收端服务，再启动发送端，接收端对应绑定的键收到对应的消息。

注：发送消息时可以设置routing_key，接收队列与转发器间可以设置binding_key，接收者接收与binding_key与routing_key相同的消息。

转载于:https://www.cnblogs.com/telwanggs/p/7124609.html

（转）RabbitMQ学习之路由（java）相关推荐

（转）RabbitMQ学习之Headers交换类型（java）
http://blog.csdn.net/zhu_tianwei/article/details/40923131 Headers类型的exchange使用的比较少,它也是忽略routingKey的一 ...
（转） RabbitMQ学习之发布/订阅（java）
http://blog.csdn.net/zhu_tianwei/article/details/40887733 参考:http://blog.csdn.NET/lmj623565791/artic ...
（转） RabbitMQ学习之远程过程调用(RPC)（java）
http://blog.csdn.net/zhu_tianwei/article/details/40887885 在一般使用RabbitMQ做RPC很容易.客户端发送一个请求消息然后服务器回复一个响 ...
（转）RabbitMQ学习之主题topic（java）
http://blog.csdn.net/zhu_tianwei/article/details/40887775 参考:http://blog.csdn.NET/lmj623565791/artic ...
RabbitMQ学习
RabbitMQ学习 1.概述用于进程通信的中间件. 优势: 劣势: 1.应用解耦:提高了系统容错性和可维护性 1.系统依赖越多不能保证MQ的高可用 2.异步提速:提升用户体验和系统吞吐量 2.复杂 ...
RabbitMQ 学习笔记
RabbitMQ 学习笔记 RabbitMQ 学习笔记 1. 中间件 1.1 什么是中间件 1.2 为什么要使用消息中间件 1.3 中间件特点 1.4 在项目中什么时候使用中间件技术 2. 中间件技术 ...
Rabbitmq学习笔记(尚硅谷2021)
Rabbitmq学习笔记 (尚硅谷) 1.MQ 的概念 1.1 什么是 MQ? 1.2 为什么要用 MQ? 削峰解耦异步 1.3 MQ 的分类 ActiveMQ Kafka RocketMQ Ra ...
乐行学院RabbitMQ学习教程第一章 RabbitMQ介绍(可供技术选型时使用)
乐行学院RabbitMQ学习教程第一章 RabbitMQ介绍 RabbitMQ介绍 1.RabbitMQ技术简介 2.RabbitMQ其他扩展插件 2.1监控工具rabbitmq-managemen ...
分布式消息中间件之RabbitMQ学习笔记[一]
写在前面嗯,陆续的整理一些中间件的笔记今天和小伙伴们分享RabbitMQ 相关笔记博文偏理论,内容涉及: RabbitMQ的简单介绍 AMQP协议标准介绍 RabbitMQ Demo 食用方式: ...

（转）RabbitMQ学习之路由（java）

（转）RabbitMQ学习之路由（java）相关推荐

最新文章

热门文章