二、利用SpringAMQP实现HelloWorld中的基础消息队列功能

1、因为publisher和consumer服务都需要amqp依赖因此这里把依赖直接放到父工程mq-demo中

2、编写yml文件

三、在consumer中编写消费逻辑监听simple.queue

2、编写yml文件

一利用SpringAMQP演示FanoutExchange的使用

1、新建config类声明交换机和队列

Framework的AMQP扩展提供了一个抽象层使得使用AMQP进行消息传递变得更加简单。

SpringAMQP支持多种消息传递模式包括点对点、发布/订阅和请求/响应等。

SpringAMQP提供了许多高级功能例如队列管理、消息确认、事务和消息过滤等。

总之SpringAMQP是一个灵活、可扩展的AMQP实现它使得使用消息队列时变得更加容易和高效。

二、利用SpringAMQP实现HelloWorld中的基础消息队列功能

1、因为publisher和consumer服务都需要amqp依赖因此这里把依赖直接放到父工程mq-demo中

!--

AMQP依赖包含RabbitMQ--dependencygroupIdorg.springframework.boot/groupIdartifactIdspring-boot-starter-amqp/artifactId/dependency

2、编写yml文件

massageaaaaaaa;rabbitTemplate.convertAndSend(queue,massage);}

三、在consumer中编写消费逻辑监听simple.queue

2、编写yml文件

org.springframework.amqp.rabbit.annotation.RabbitListener;

import

org.springframework.stereotype.Component;Component

public

msg){System.out.println(消费者接收到消息msg);}

}4、运行并测试

{rabbitTemplate.convertAndSend(queue,massage);}}

Component

msg){System.out.println(消费者0接收到消息msg

LocalTime.now());try

RuntimeException(e);}}RabbitListener(queues

simple.queue)public

msg){System.err.println(消费者1接收到消息__________-msg

LocalTime.now());try

这是因为消费预取机制会让消费者事先分配好要处理的消息而不是按能力分配

#表示预取上限为1

一利用SpringAMQP演示FanoutExchange的使用

1、新建config类声明交换机和队列

FanoutExchange(itcast.fanout);}Beanpublic

Queue

Queue(fanout.queue1);}Beanpublic

Binding

BindingBuilder.bind(fanoutQueue1).to(exchange);}///2Beanpublic

Queue

Queue(fanout.queue2);}Beanpublic

Binding

BindingBuilder.bind(fanoutQueue2).to(exchange);}

2、启动项目查看配置

msg){System.err.println(消费者1接收到消息__________-msg

LocalTime.now());}RabbitListener(queues

fanout.queue2)public

msg){System.err.println(消费者2接收到消息__________-msg

LocalTime.now());}

One;rabbitTemplate.convertAndSend(exchangeName,,message);}

5、运行代码观察输出

接收publisher发送的消息将消息按照规则路由到与之绑定的队列不能缓存消息路由失败消息丢失FanoutExchange的会将消息路由到每个绑定的队列

四DirectExchange

msg){System.err.println(消费者1接收到消息__________-msg

LocalTime.now());}RabbitListener(bindings

QueueBinding(value

msg){System.out.println(消费者2接收到消息__________-msg

LocalTime.now());}

One1111;rabbitTemplate.convertAndSend(exchangeName,blue,message);}

Testpublic

One1111;rabbitTemplate.convertAndSend(exchangeName,red,message);}

Fanout交换机将消息路由给每一个与之绑定的队列Direct交换机根据RoutingKey判断路由给哪个队列如果多个队列具有相同的RoutingKey则与Fanout功能类似

基于RabbitListener注解声明队列和交换机有哪些常见注解

QueueExchange

msg){System.out.println(消费者1接收到消息aaaaaa__-msg

LocalTime.now());}RabbitListener(bindings

QueueBinding(value

msg){System.err.println(消费者2接收到消息a__-msg

LocalTime.now());}

One12222;rabbitTemplate.convertAndSend(exchangeName,china.news,message);}

3、运行测试

HashMap();message.put(name,11);message.put(age,22);rabbitTemplate.convertAndSend(object.queue,message);}

3、查看

dependencygroupIdcom.fasterxml.jackson.core/groupIdartifactIdjackson-databind/artifactId/dependency

添加配置Bean

Jackson2JsonMessageConverter();}

5、接收消息

Jackson2JsonMessageConverter();}

编写消费者代码

listenObjectQueue1(MapString,Object

msg){System.err.println(消费者接收到消息___da_______-msg

LocalTime.now());