python网页版_浏阳最新疫情最新消息_搜索引擎营销实训报告_广告联盟点击赚钱平台

使用 spring-amqp 实验

发布订阅模型

fanoutExchange 实验

实验步骤：

1. 编写定义 队列 和 交换机 绑定关系的代码
2. 创建接口，模拟生产者，方便调试（接受参数 队列名、路由键、[消息]）
3. 定义消费者
   代码示例：

@Configuration
public class FanoutConfig {@Beanpublic FanoutExchange fanoutexchange() {//创建广播模式交换机return new FanoutExchange("yoj.fanoutexchange");}// 创建队列@Beanpublic Queue fanoutQueue() {return new Queue("fanout.queue1");}// 绑定交换机和队列之间的关系@Beanpublic Binding bindingQueue1(Queue fanoutQueue1, FanoutExchange fanoutExchange) {return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}
}

 @GetMapping("/testMQ/{queueName}/{routingKey}")public BaseResponse<String> testMQ(@PathVariable("queueName") String queueName, @PathVariable("routingKey") String routingKey) {rabbitTemplate.convertAndSend(queueName, routingKey, "编译执行代码，返回结果");return ResultUtils.success("发送成功");}

实验效果

发消息

在队列中接受到了消息

direct 案例

• 定义 关系

 @RabbitListener(bindings = @QueueBinding(value=@Queue("direct.queue1"), exchange = @Exchange(name="direct.exchange", type = ExchangeTypes.DIRECT), key={"direct.key1"}))public void directQueue1Listen(String in) {System.out.println("direct.queue1:Received message: " + in);}@RabbitListener(bindings = @QueueBinding(value=@Queue("direct.queue2"), exchange = @Exchange(name="direct.exchange", type = ExchangeTypes.DIRECT),  key={"direct.key2"}))public void directQueue2listen(String in) {System.out.println("direct.queue2:Received message: " + in);}