java操作RabbitMQ速通

docker部署rabbitMQ

由于常规的rabbitMQ部署需要配置很多依赖，而且容易因为版本的问题而导致部署失败，所以这里采用docker部署方式，不认识docker部署的可以看下面这篇文章：
Docker部署基础快速入门-CSDN博客
拉取镜像

1. docker pull rabbitmq:management

复制代码

如果出现因网络而拉取失败的可以参考以下文章：
2024 最新docker仓库镜像，6月，7月_最新docker镜像源-CSDN博客
启动容器

1. docker run -e RABBITMQ_DEFAULT_USER=root
2. -e RABBITMQ_DEFAULT_PASS=1234
3. -v mq-plugins:/plugins
4. --name mq3
5. -p 15672:15672
6. -p 5672:5672
7. -d rabbitmq:management

复制代码

如果出现启动容器后容器立刻关闭可以参考以下文章：
docker启动容器之后立刻又自动关闭了_docker 容器 启动又秒退-CSDN博客
如果还不行，就查抄容器日志：

1. docker logs 容器名

复制代码

如果出现下面的报错：

1. Failed to create thread: Operation not permitted (1)

复制代码

可以在启动容器的下令中参加以下下令：

1. --privileged=true

复制代码

启动成功后检察运行的容器：

1. docker ps

复制代码

 成功后显示：

访问http://localhost:15672/显示：

rabbitMQ数据隔离

一个rabbitMQ服务下可能有多个消耗者和生产者，不同的服务之间需要举行数据隔离，我们可以通过在rabbitMQ主机中创建虚拟主机来实现数据隔离
创建一个用户： 

利用创建的用户再次登录后为该用户创建一个虚拟主机：

如许一来，不同的用户访问各自的虚拟主机，服务之间的数据也就隔离开来了。 
Spring AMQP

Spring AMQP (Asynchronous Message Passing Protocol) 是 Spring Framework 的一个扩展模块，用于简化基于 AMQP (Advanced Message Queuing Protocol) 的消息中间件（如 RabbitMQ）的集成。
pom.xml引入依赖

1.         <dependency>
2.             <groupId>org.springframework.boot</groupId>
3.             <artifactId>spring-boot-starter-amqp</artifactId>
4.         </dependency>

复制代码

yml配置

消耗者端

1. spring:
2.   application:
3.      name: consumer
5.   rabbitmq:
6.      host: localhost
7.      port: 5672
8.      virtual-host: /demo #主机下的虚拟机名
9.      username: root2
10.      password: 1234

复制代码

生产者端

1. spring:
2.   application:
3.      name: producer
5.   rabbitmq:
6.      host: localhost
7.      port: 5672
8.      virtual-host: /demo #主机下的虚拟机名
9.      username: root2
10.      password: 1234

复制代码

消息推送和接收

在rabbitMQweb端创建一个队列：

 消息推送：

测试样例：

1. @SpringBootTest
2. class Demo1ApplicationTests {
3.     @Resource
4.     private RabbitTemplate rabbitTemplate;
5.     @Test
6.     void contextLoads() {
7.          String QueueName="demo.queue";
8.          String msg="hello rabbitmq";
9.          rabbitTemplate.convertAndSend(QueueName,msg);
10.     }
12. }

复制代码

消息接收：
创建一个监听器类：
样比方下：

1. @Component
2. public class RabbbitmqDemo {
4.     @RabbitListener(queues = "demo.queue")
5.     public void receiveMsg(String msg){
6.         System.out.println(msg);
7.     }
9. }

复制代码

 先运行生产者后运行消耗者，运行效果如下：

work模子

work模子简而言之就是多个消耗者绑定一个队列，从而提高消息处理处罚的速率，

 同时要记得在yml文件中配置以下信息，否则就会出现一个快的消耗者和一个慢的消耗者同时拉取到雷同数目标消息，正常的情况应该是快的处理处罚的消息要多，如许才能充实利用起多个消耗者协同合作的性能：

1. spring:
2.   application:
3.      name: consumer
5.   rabbitmq:
6.      host: localhost
7.      port: 5672
8.      virtual-host: /demo #主机下的虚拟机名
9.      username: root2
10.      password: 1234     listener:       simple:         prefetch: 1 #每次只能获取一条消息，处理处罚完才能获取下一条消息

复制代码

交换机

以上消息推送和接收均是访问队列，而在实际的开发中是先访问交换机后，由交换机来转发消息给队列，常见的交换机有以下几种： 
fanout

一个交换机分发给多个队列：

direct

也就是每个队列都会与一个key相干联，好比我有一个付出业务，那么这个业务就可以将消息发送给所有与"pay"（实际的key要在向交换机中添加队列时自定义）绑定的队列

topic

topic与direct最大的不同就是它可以根据通配符绑定好比在发送消息时绑定key=“pay.#”,那么消息就会发送给所有和雷同于（"pay.red","pay.yellow","pay.blue"）的关键词绑定的队列

在java中定义交换机和队列

在rabbitmq网页端定义交换机和队列，难免有些贫苦，下面提供了一种在java代码中定义交换机和队列的方式：
这里只需要在消耗者监听器上添加以下的注解，如果是fanout交换机，那么就可以省略key的定义（此注解为样例实际需要本身根据模板定义）：

1.     @RabbitListener(bindings = @QueueBinding(
2.             value=@Queue(name="队列名",durable = "true"可持久化设置,true代表开启),
3.             exchange = @Exchange(name="交换机名",type = ExchangeTypes.DIRECT 交换机类型),
4.             key={"red","yellow"}和队列绑定的key
5.     ))

复制代码

然后在生产者端定义交换机名和key就可以发送到特定的队列中，如果是fanout交换机，那么就可以省略key的定义

1. @SpringBootTest
2. class Demo1ApplicationTests {
3.     @Resource
4.     private RabbitTemplate rabbitTemplate;
5.     @Test
6.     void contextLoads() {
7.         String ExchangeName="交换机名";
8.         String msg="hello rabbitmq";
9.         rabbitTemplate.convertAndSend(ExchangeName,"key的名称",msg);
10.     }
12. }

复制代码

消息转换器

除了字符串范例的对象，可能在实际开发中还需要其他的对象消息好比User，Map等，这个时候要想在消息队列中存储这些对象的json格式就需要用到消息转换器来实现转换，配置消息转换器的步调如下：

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。