rabbitmq+topic+java_译:5.RabbitMQ Java Client 之 Topics (主题)

我们使用的是direct(直接交换),而不是使用只能进行虚拟广播的 fanout(扇出交换),并且有可能选择性地接收日志。

虽然使用direct(直接交换)改进了我们的系统,但它仍然有局限性 - 它不能基于多个标准进行路由。

在我们的日志系统中,我们可能不仅要根据严重性订阅日志,还要根据发出日志的源来订阅日志。您可能从syslogunix工具中了解这个概念,该工具根据严重性(info / warn / crit ...)和facility(auth / cron / kern ...)来路由日志。

这会给我们带来很大的灵活性 - 我们可能想听听来自'cron'的关键错误以及来自'kern'的所有日志。

要在我们的日志系统中实现这一点,我们需要了解更复杂的topic (主题交换)。

Topic exchange 主题交换

发送到主题交换的消息不能具有任意routing_key- 它必须是由点分隔的单词列表。单词可以是任何内容,但通常它们指定与消息相关的一些功能。一些有效的路由密钥示例:“stock.usd.nyse”,“nyse.vmw”,“quick.orange.rabbit”。路由密钥中可以包含任意数量的单词,最多可达255个字节。

绑定密钥也必须采用相同的形式。主题交换背后的逻辑类似于直接交换- 使用特定路由密钥发送的消息将被传递到与匹配绑定密钥绑定的所有队列。但是,绑定键有两个重要的特殊情况:

*(星号)可以替代一个单词。

#(hash)可以替换零个或多个单词。

在一个例子中解释这个是最容易的:

be3e3aab15b07949c2704f7e995f78ac.png

在这个例子中,我们将发送所有描述动物的消息。消息将与包含三个单词(两个点)的路由键一起发送。

路由键中的第一个单词将描述速度,第二个是颜色,第三个是物种:“。。”。

我们创建了三个绑定:Q1绑定了绑定键“* .orange。*”,Q2绑定了“*。*。rabbit”和“lazy。#”。

这些绑定可以概括为:

Q1对所有橙色动物感兴趣。

Q2希望听到关于兔子的一切,以及关于懒惰动物的一切。

路由密钥设置为“quick.orange.rabbit”的消息将传递到两个队列。消息“lazy.orange.elephant”也将同时发送给他们。另一方面,“quick.orange.fox”只会进入第一个队列,而“lazy.brown.fox”只会进入第二个队列。“lazy.pink.rabbit”将仅传递到第二个队列一次,即使它匹配两个绑定。“quick.brown.fox”与任何绑定都不匹配,因此它将被丢弃。

如果我们违反合同并发送带有一个或四个单词的消息,例如“orange”或“quick.orange.male.rabbit”,会发生什么?好吧,这些消息将不匹配任何绑定,将丢失。

另一方面,“lazy.orange.male.rabbit”,即使它有四个单词,也会匹配最后一个绑定,并将被传递到第二个队列。

主题交流

主题交换功能强大,可以像其他交易所一样。

当队列与“#”(哈希)绑定密钥绑定时 - 它将接收所有消息,而不管路由密钥 - 如扇出交换。

当特殊字符“*”(星号)和“#”(哈希)未在绑定中使用时,主题交换的行为就像直接交换一样

把它们放在一起

我们将在日志记录系统中使用主题交换。我们将首先假设日志的路由键有两个词:“。”。

EmitLogTopic.java

importcom.rabbitmq.client.BuiltinExchangeType;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;public classEmitLogTopic {private static final String EXCHANGE_NAME = "topic_logs";public static voidmain(String[] argv) {

Connection connection= null;

Channel channel= null;try{

ConnectionFactory factory= newConnectionFactory();

factory.setHost("localhost");

connection=factory.newConnection();

channel=connection.createChannel();

channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);

String routingKey=getRouting(argv);

String message=getMessage(argv);

channel.basicPublish(EXCHANGE_NAME, routingKey,null, message.getBytes("UTF-8"));

System.out.println(" [x] Sent '" + routingKey + "':'" + message + "'");

}catch(Exception e) {

e.printStackTrace();

}finally{if (connection != null) {try{

connection.close();

}catch(Exception ignore) {

}

}

}

}private staticString getRouting(String[] strings) {if (strings.length < 1)return "anonymous.info";return strings[0];

}private staticString getMessage(String[] strings) {if (strings.length < 2)return "Hello World!";return joinStrings(strings, " ", 1);

}private static String joinStrings(String[] strings, String delimiter, intstartIndex) {int length =strings.length;if (length == 0)return "";if (length

StringBuilder words= newStringBuilder(strings[startIndex]);for (int i = startIndex + 1; i < length; i++) {

words.append(delimiter).append(strings[i]);

}returnwords.toString();

}

}

ReceiveLogsTopic.java

importjava.io.IOException;importcom.rabbitmq.client.AMQP;importcom.rabbitmq.client.BuiltinExchangeType;importcom.rabbitmq.client.Channel;importcom.rabbitmq.client.Connection;importcom.rabbitmq.client.ConnectionFactory;importcom.rabbitmq.client.Consumer;importcom.rabbitmq.client.DefaultConsumer;importcom.rabbitmq.client.Envelope;public classReceiveLogsTopic {private static final String EXCHANGE_NAME = "topic_logs";public static void main(String[] argv) throwsException {

ConnectionFactory factory= newConnectionFactory();

factory.setHost("localhost");

Connection connection=factory.newConnection();

Channel channel=connection.createChannel();

channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);

String queueName=channel.queueDeclare().getQueue();if (argv.length < 1) {

System.err.println("Usage: ReceiveLogsTopic [binding_key]...");

System.exit(1);

}for(String bindingKey : argv) {

channel.queueBind(queueName, EXCHANGE_NAME, bindingKey);

}

System.out.println(" [*] Waiting for messages. To exit press CTRL+C");

Consumer consumer= newDefaultConsumer(channel) {

@Overridepublic voidhandleDelivery(String consumerTag, Envelope envelope,

AMQP.BasicProperties properties,byte[] body) throwsIOException {

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

System.out.println(" [x] Received '" + envelope.getRoutingKey() + "':'" + message + "'");

}

};

channel.basicConsume(queueName,true, consumer);

}

}

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/559189.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

php 查找无限级,Ztree + PHP 无限级节点 递归查找节点法

一、前言简单的描述一下&#xff0c;实习几个原理&#xff0c;思想&#xff0c;其实写很多东西&#xff0c;思想算是最重要的。1、目标&#xff1a;将写一个无限节点的树形目录结构&#xff0c;如下图步骤&#xff1a;1、你的下载 插件 ztree。然后布置在你的项目中。2、相关C…

用php实现一个简易的web表单生成器,网络编程PHP Web表单生成器案例分析

本文实例讲述了PHP Web表单生成器。分享给大家供大家参考&#xff0c;具体如下&#xff1a;1.实例&#xff1a;2. 需求分析在项目的实际开发中&#xff0c;经常需要设计各种各样表单。直接编写HTML表单虽然简单&#xff0c;但修改、维护相对麻烦。因此&#xff0c;可以利用PHP实…

matlab示波器有功功率,巧用示波器计算功率-测试测量-与非网

示波器主要用于测量电流和电压&#xff0c;然后通过一系列魔术般的数学公式就可以计算出功率。遗憾的是&#xff0c;功率有许多种类&#xff1a;瞬时功率、有功功率、视在功率和无功功率。这么多的功率术语经常让人感到困惑。本文介绍了如何在Teledyne LeCroy HDO 6000示波器上…

php 表单提交文件大小,PHP如何通过表单直接提交大文件详解

PHP如何通过表单直接提交大文件详解前言我想通过表单直接提交大文件&#xff0c;django 那边我就是这么干的。而对于 php 来说&#xff0c;我认为尽管可以设置最大上传的大小&#xff0c;但最大也无法超过内存大小&#xff0c;因为它无法把文件内容都放到 php://input 里面。直…

php登陆项目,ThinkPHP6项目基操(14.实战部分 中间件处理登录流程)

一、定义中间件namespace app\middleware;class Check{public function handle($request, \Closure $next){if ($request->param(name) think) {return redirect(index/think);}return $next($request);}}中间件类可以随意命名&#xff0c;中间件的入口执行方法必须是handl…

蓝桥杯第七届决赛之---阶乘位数

阶乘位数9的阶乘等于&#xff1a;362880它的二进制表示为&#xff1a;1011000100110000000这个数字共有19位。请你计算&#xff0c;9999 的阶乘的二进制表示一共有多少位&#xff1f; 思路总结&#xff1a; 根据平时做题规律得到如下规律&#xff1a;public class SwingDesign …

生日快乐模板php,可会有人跟我说句生日快乐

一个人一年可以经历三百六十五次零点的跨越&#xff0c;可是真正有意义的却只有那么一次。从呱呱坠地到现在芳华正茂&#xff0c;今晚将是我要度过的第二十二个零点。从此以后&#xff0c;我便会进入到一个崭新的年龄&#xff0c;弱弱的问一句&#xff1a;可会有人跟我说句生日…

Java排序算法之--快速算法--快速上手

何为快速算法&#xff1a;它是冒泡排序的改进~ 基本思想是&#xff1a;通过一趟排序将要排序的数据分割成独立的两部分&#xff0c;其中一部分的所有数据都比另外一部分的所有数据都要小&#xff0c;然后再按此方法对这两部分数据分别进行快速排序&#xff0c;整个排序过程可以…

排序算法值--堆排序

堆实际上是一棵完全二叉树&#xff0c;其任何一非叶节点满足性质&#xff1a;Key[i]<key[2i1]&&Key[i]<key[2i2]或者Key[i]>Key[2i1]&&key>key[2i2]即任何一非叶节点的关键字不大于或者不小于其左右孩子节点的关键字。堆分为大顶堆和小顶堆&#x…

linux 彻底删除oracle,Linux下完美卸载Oracle

先说一下Linux 下Oracle没有卸载干净再安装会出现什么后果吧&#xff0c;在一次生产环境安装中&#xff0c;装Oracle时出现一个错误&#xff0c;倒致oracle没有安先说一下Linux 下Oracle没有卸载干净再安装会出现什么后果吧&#xff0c;在一次生产环境安装中&#xff0c;装Orac…

spring常见术语理解

SpringMVC工作流程&#xff1a;流程 1、用户发送请求至前端控制器DispatcherServlet 2、DispatcherServlet收到请求调用HandlerMapping处理器映射器。 3、处理器映射器找到具体的处理器&#xff0c;生成处理器对象及处理器拦截器(如果有则生成)一并返回给DispatcherServlet。 …

linux ssh服务,Linux配置SSH服务以便实现远程连接

Linux用户们一定想要知道该怎么开启SSH服务吧&#xff0c;SSH服务是Linux系统远程连接的重要方式&#xff0c;所以如何配置SHH服务也让很多用户感到纠结。现在小编就帮大家解决这个问题。配置方法&#xff1a;查询\安装SSH服务1.登陆linux系统&#xff0c;打开终端命令。输入 r…

玄学········为什么在eclipse上更改程序之后运行之后好像没更改一样

更改了半天&#xff0c;保存的了很多次&#xff0c;错误也改掉了&#xff0c;但是还是报同一个错误&#xff0c;很痛苦~搜了半天&#xff0c;终于搞定了&#xff0c;方法总结如下&#xff1a;一 可能是有一些文件没报存&#xff0c;设置让其自动保存&#xff1a;1 Windows-&g…

转圈打印矩阵~~

下面附上程序&#xff0c;欢迎各位前来讨论&#xff1a; package jian_zhi_offer;public class code29_PrintMatrixClockWisely {public static void main(String args[]) {int arr[][] { { 1, 2, 3, 4 }, { 5, 6, 7, 8 }, { 9, 10, 11, 12 } };printMatrix(arr);}/* 这个函数…

“之”字形打印矩阵~

编程如下&#xff1a; 欢迎大家前来讨论~ public class PrintMatirx { public static void main(String args[]) { int arr[][] { { 1, 2, 3, 4 }, { 5, 6, 7, 8 }, { 9, 10, 11, 12 } }; printZigMatrix(arr); } public static void printZigMatrix(int arr[][]) { int row1 …

linux设备probe,你了解Embeded linux中的probe

一、基于linux-3.18.20、mac驱动二、启动时机&#xff1a;所谓的"probe”&#xff0c;是指在Linux内核中&#xff0c;如果存在相同名称的device和device_driver&#xff0c;内核就会执行device_driver中的probe回调函数&#xff0c;而该函数就是所有driver的入口&#xff…

在行列都排好序的矩阵中找数

对于这种题&#xff0c;首先要读懂该题的题意&#xff0c;首先是有序的&#xff0c;然后就判断K是否存在数组中。 仔细研究这个题之后不难发现一个规律&#xff0c;咱们定义右上角的坐标为&#xff08;row&#xff0c;col&#xff09;则有如下规律&#xff1a;程序如下&#xf…

打印两个有序链表的公共部分~~

类似与归并排序&#xff0c;这里就不再赘述了~

透彻理解回文~单链表的逆序~

判断一个单链表是不是回文&#xff0c;主要有三种方法&#xff0c;不过如果要考虑空间复杂度的话&#xff0c;就只有常用的一种方法了。 这种方法很考验一个人的细心以及编程能力~ 前两种方法比较简单我就不祥述了~ 主要讲一下最后一种方法&#xff1a;直接上图了~下面附上code…

linux下nand flash驱动工作原理,Linux驱动之Nand Flash四问,原理、工作方式都包含了...

Nand Flash 是一个存储芯片。本文引用地址&#xff1a;http://www.eepw.com.cn/article/201801/374606.htm那么&#xff1a;这样的操作很理“读地址A的数据&#xff0c;把数据B写到地址A”问1&#xff1a;原理图上的Nand Flash和SC2440之间只有数据线&#xff0c;怎么传输地址?…