网站设计哪家比较好,推广普通话的法律依据主要有,郑州东区做网站的公司,wordpress获取当前分类别名Topic消费模型
* 通配符模型
* 生产者必须指定完整且准确的路由key
* 消费者可以使用通配符
* *#xff1a;可以替代一级的任意字符 add.* add.user add.goods
* ##xff1a;可以替代多级的任意字符 add.# 可以替代一级的任意字符 add.* add.user add.goods
* #可以替代多级的任意字符 add.# add.user.name add.user.name.firstName生产者
package com.example.demo02.mq.topic;import com.example.demo02.mq.util.ConnectionUtils;
import com.rabbitmq.client.BuiltinExchangeType;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;import java.io.IOException;/*** author Allen* 4/11/2024 10:15 AM* version 1.0* description: 通配符模型发送者* 通配符模型* 生产者必须指定完整且准确的路由key* 消费者可以使用通配符* *可以替代一级的任意字符 add.* add.user add.goods* #可以替代多级的任意字符 add.# add.user.name add.user.name.firstName*/
public class TopicSender {public static void main(String[] args) throws Exception {// 1获取连接Connection connection ConnectionUtils.getConnection();// 2创建通道Channel channel connection.createChannel();// 3声明交换机channel.exchangeDeclare(topic.exchange, BuiltinExchangeType.TOPIC,false);// 4发送消息 路由Key写法 goods.add 不要使用通配符String msg1 商品新增了Topic模型routing key 为 goods.add;String msg2 商品修改了Topic模型routing key 为 goods.update;String msg3 商品删除了Topic模型routing key 为 goods.delete;String msg4 用户新增了Topic模型routing key 为 user.add;String msg5 用户修改了Topic模型routing key 为 user.update;String msg6 用户删除了Topic模型routing key 为 user.delete;String msg7 添加了用户名字Topic模型routing key 为 user.add.name;String msg8 添加了用户年龄Topic模型routing key 为 user.add.age;String msg9 修改了用户名字Topic模型routing key 为 user.update.name;String msg10 修改了用户年龄Topic模型routing key 为 user.update.age;channel.basicPublish(topic.exchange,goods.add,null,msg1.getBytes());channel.basicPublish(topic.exchange,goods.update,null,msg2.getBytes());channel.basicPublish(topic.exchange,goods.delete,null,msg3.getBytes());channel.basicPublish(topic.exchange,user.add,null,msg4.getBytes());channel.basicPublish(topic.exchange,user.update,null,msg5.getBytes());channel.basicPublish(topic.exchange,user.delete,null,msg6.getBytes());channel.basicPublish(topic.exchange,user.add.name,null,msg7.getBytes());channel.basicPublish(topic.exchange,user.add.age,null,msg8.getBytes());channel.basicPublish(topic.exchange,user.update.name,null,msg9.getBytes());channel.basicPublish(topic.exchange,user.update.age,null,msg10.getBytes());// 5关闭连接channel.close();connection.close();}
}消费者1
package com.example.demo02.mq.topic;import com.example.demo02.mq.util.ConnectionUtils;
import com.rabbitmq.client.*;import java.io.IOException;/*** author Allen* 4/11/2024 10:22 AM* version 1.0** description: 通配符模型接收者1*/
public class TopicReceiver1 {public static void main(String[] args) throws Exception {// 1获取连接Connection connection ConnectionUtils.getConnection();// 2创建通道Channel channel connection.createChannel();// 3声明交换机channel.exchangeDeclare(topic.exchange, BuiltinExchangeType.TOPIC,false);// 4声明队列channel.queueDeclare(topic.queue1, false, false, false, null);// 5绑定队列到交换机 使用通配符* 一级任意字符 # 多级任意字符channel.queueBind(topic.queue1, topic.exchange, goods.*);// 6消费消息Consumer consumer new DefaultConsumer(channel){Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(商品模块接收到的消息是 new String(body));channel.basicAck(envelope.getDeliveryTag(),false);}};channel.basicConsume(topic.queue1,false,consumer);}
}消费者2
package com.example.demo02.mq.topic;import com.example.demo02.mq.util.ConnectionUtils;
import com.rabbitmq.client.*;import java.io.IOException;/*** author Allen* 4/11/2024 10:22 AM* version 1.0** description: 通配符模型接收者2*/
public class TopicReceiver2 {public static void main(String[] args) throws Exception {// 1获取连接Connection connection ConnectionUtils.getConnection();// 2创建通道Channel channel connection.createChannel();// 3声明交换机channel.exchangeDeclare(topic.exchange, BuiltinExchangeType.TOPIC,false);// 4声明队列channel.queueDeclare(topic.queue2, false, false, false, null);// 5绑定队列到交换机 使用通配符 user.* user.#channel.queueBind(topic.queue2, topic.exchange, user.#);// 6消费消息Consumer consumer new DefaultConsumer(channel){Overridepublic void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties properties, byte[] body) throws IOException {System.out.println(用户模块接收到的消息是 new String(body));channel.basicAck(envelope.getDeliveryTag(),false);}};channel.basicConsume(topic.queue2,false,consumer);}
}结果
