5.主题模式

在路由模式中,应用Direct交换机，从而能够选择性接管日志。

尽管应用Direct交换机改良了咱们的零碎，但它不能基于多个规范进行路由。

这是不足灵活性的,要在日志零碎中实现这一点，咱们须要理解更简单的Topic交换机。

主题交换机 Topic exchange

发送到Topic交换机的音讯,它的的routingKey,必须是由点分隔的多个单词。单词能够是任何货色，但通常是与音讯相干的一些个性。

routingKey能够有任意多的单词，最多255个字节。

bindingKey也必须采纳雷同的模式。Topic交换机的逻辑与直连交换机相似——应用特定routingKey发送的音讯将被传递到所有应用匹配bindingKey绑定的队列。bindingKey有两个重要的非凡点:

  • * 能够通配单个单词。
  • # 能够通配零个或多个单词。

如图所示:

如上图中,将routingKey设置为"quick.orange.rabbit"的音讯将被发送到两个队列。音讯 "lazy.orange.elephant“也发送到它们两个。另外”quick.orange.fox“只会发到第一个队列，”lazy.brown.fox“只发给第二个。”lazy.pink.rabbit“将只被传递到第二个队列一次，即便它匹配两个绑定。”quick.brown.fox"不匹配任何绑定，因而将被抛弃。

生产者

public class Test1 {    public static void main(String[] args) throws Exception {        ConnectionFactory f = new ConnectionFactory();        f.setHost("192.168.64.140");        f.setPort(5672);        f.setUsername("admin");        f.setPassword("admin");                Connection c = f.newConnection();        Channel ch = c.createChannel();                //参数1: 交换机名        //参数2: 交换机类型        ch.exchangeDeclare("topic_logs", BuiltinExchangeType.TOPIC);                while (true) {            System.out.print("输出音讯: ");            String msg = new Scanner(System.in).nextLine();            if ("exit".contentEquals(msg)) {                break;            }            System.out.print("输出routingKey: ");            String routingKey = new Scanner(System.in).nextLine();                        //参数1: 交换机名            //参数2: routingKey, 路由键,这里咱们用日志级别,如"error","info","warning"            //参数3: 其余配置属性            //参数4: 公布的音讯数据             ch.basicPublish("topic_logs", routingKey, null, msg.getBytes());                        System.out.println("音讯已发送: "+routingKey+" - "+msg);        }        c.close();    }}

消费者

public class Test2 {    public static void main(String[] args) throws Exception {        ConnectionFactory f = new ConnectionFactory();        f.setHost("192.168.64.140");        f.setUsername("admin");        f.setPassword("admin");        Connection c = f.newConnection();        Channel ch = c.createChannel();                ch.exchangeDeclare("topic_logs", BuiltinExchangeType.TOPIC);                //主动生成对列名,        //非长久,独占,主动删除        String queueName = ch.queueDeclare().getQueue();                System.out.println("输出bindingKey,用空格隔开:");        String[] a = new Scanner(System.in).nextLine().split("\\s");                //把该队列,绑定到 topic_logs 交换机        //容许应用多个 bindingKey        for (String bindingKey : a) {            ch.queueBind(queueName, "topic_logs", bindingKey);        }                System.out.println("期待接收数据");                //收到音讯后用来解决音讯的回调对象        DeliverCallback callback = new DeliverCallback() {            @Override            public void handle(String consumerTag, Delivery message) throws IOException {                String msg = new String(message.getBody(), "UTF-8");                String routingKey = message.getEnvelope().getRoutingKey();                System.out.println("收到: "+routingKey+" - "+msg);            }        };                //消费者勾销时的回调对象        CancelCallback cancel = new CancelCallback() {            @Override            public void handle(String consumerTag) throws IOException {            }        };                ch.basicConsume(queueName, true, callback, cancel);    }}

6.RPC模式

该模式不常应用,也较为简单,理解即可.
RPC模式顾名思义也就是近程调用模式.

RabbitMQ去搭建一个RPC零碎：一个客户端和一个能够降级(扩大)的RPC服务器

总结:
RPC的工作形式是这样的:

  • 对于RPC申请，客户端发送一条带有两个属性的音讯:replyTo,设置为仅为申请创立的匿名独占队列,和correlationId,设置为每个申请的惟一id值。
  • 申请被发送到rpc_queue队列。
  • RPC工作过程(即:服务器)在队列上期待申请。当一个申请呈现时，它执行工作,并应用replyTo字段中的队列将后果发回客户机。
  • 客户机在回应音讯队列上期待数据。当音讯呈现时，它查看correlationId属性。如果匹配申请中的值，则向程序返回该响应数据。