码迷,mamicode.com
首页 > 其他好文 > 详细

topics

时间:2017-06-17 19:38:08      阅读:204      评论:0      收藏:0      [点我收藏+]

标签:exchange   条件   sicp   war   消息   不同的   uil   日志   灵活   

 

由于使用fanout类型的exchange只能进行全局的广播,因此我们使用direct类型的exchange做了代替, 使得我们可以选择性的接收消息。尽管使用fanout exchange改进了log系统,但它仍然有限制——不能基于多个条件做路由。

在log系统中可能不只是基于不同的日志级别作订阅,也可能会基于日志的来源。你也许听过Unix下名为syslog的工具, 它把日志按照严重级别(info/warn/crit…)和设备(auth/cron/ker…)进行路由。

这会给我们许多的灵活性,也许我们只想监听’cron’中的’critical’级别的错误日志,以及所有’kern’中的日志。 为了实现这种日志系统,我们需要学习一个更复杂的topic类型的exchange。

发送到topic exchange中的消息不能有一个任意的routing_key——它必须是一个使用点分隔的单词列表。单词可以是任意的, 但是通常会指定消息的一些特定。一些有效的routing key例子:”stock.usd.nyse”,”nyse.vmw”,”quick.orange.rabbit”。 routing key的长度限制为255个字节数。

binding key也必须是相同的形式。topic exchange背后的逻辑类似于direct——一条使用特定的routing key发送的消息将会被传递至所有使用与该routing key相同的binding key进行绑定的队列中。 然而,对binding key来说有两种特殊的情况:

  1. *(star)可以代替任意一个单词

  2. #(hash)可以代替0个或多个单词

发布消息

channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);

   
          String message = "helloworld";
          String routingKey="quick.orange.rabbit";
          //routekey是使用 . 分割的单词列表
          channel.basicPublish(EXCHANGE_NAME, routingKey, null, message.getBytes("UTF-8"));

订阅消息

  channel.exchangeDeclare(EXCHANGE_NAME, BuiltinExchangeType.TOPIC);
    String queueName = channel.queueDeclare().getQueue();
      channel.queueBind(queueName, EXCHANGE_NAME, "*.orange.*");

 

topics

标签:exchange   条件   sicp   war   消息   不同的   uil   日志   灵活   

原文地址:http://www.cnblogs.com/woms/p/7040869.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!