当前位置： 首页 > wzjs >正文

海南网站建设中心网络推广服务协议

wzjs 2025/7/27 18:22:22
海南网站建设中心,网络推广服务协议,鱼头seo推广,广东佛山南海区疫情最新情况RabbitMQ安装与使用教程（含Spring Boot整合） 一、RabbitMQ简介 RabbitMQ是一个开源的消息代理软件，实现了高级消息队列协议（AMQP），在分布式系统中广泛用于异步通信、解耦组件以及流量削峰等场景。它支持多…

RabbitMQ安装与使用教程（含Spring Boot整合）

一、RabbitMQ简介

RabbitMQ是一个开源的消息代理软件，实现了高级消息队列协议（AMQP），在分布式系统中广泛用于异步通信、解耦组件以及流量削峰等场景。它支持多种消息模式，如点对点、发布/订阅等，具备高可靠性、可扩展性和丰富的功能特性。

二、RabbitMQ安装

1. 安装Erlang环境

RabbitMQ是用Erlang语言编写的，因此需要先安装Erlang运行环境。以下以Ubuntu系统为例进行安装：
• 更新软件包列表：
bash sudo apt-get update
• 安装Erlang：
bash sudo apt-get install erlang

2. 安装RabbitMQ

• 添加RabbitMQ官方仓库：
bash echo "deb https://dl.bintray.com/rabbitmq/debian $(lsb_release -sc) main" | sudo tee /etc/apt/sources.list.d/rabbitmq.list
• 导入仓库密钥：
bash wget -O - 'https://dl.bintray.com/rabbitmq/Keys/rabbitmq-release-signing-key.asc' | sudo apt-key add -
• 再次更新软件包列表并安装RabbitMQ：
bash sudo apt-get update sudo apt-get install rabbitmq-server

3. 启动RabbitMQ服务

• 启动服务：
bash sudo systemctl start rabbitmq-server
• 查看服务状态：
bash sudo systemctl status rabbitmq-server

4. 访问RabbitMQ管理界面

RabbitMQ自带一个方便的管理界面，通过以下命令开启：

sudo rabbitmq-plugins enable rabbitmq_management

然后在浏览器中访问 http://服务器IP地址:15672 ，默认用户名和密码都是 guest ，登录后可以进行各种管理操作。

三、Spring Boot整合RabbitMQ

1. 创建Spring Boot项目

可以使用Spring Initializr（https://start.spring.io/ ）快速创建一个Spring Boot项目，在依赖中添加 Spring for RabbitMQ 。在项目创建过程中，选择合适的Java版本和Spring Boot版本，并添加 spring-boot-starter-amqp 依赖。

2. 配置application.properties或application.yml

在 src/main/resources 目录下的 application.properties （或 application.yml ）文件中添加RabbitMQ连接信息：

spring.rabbitmq.host=localhost
spring.rabbitmq.port=5672
spring.rabbitmq.username=guest
spring.rabbitmq.password=guest

四、定义一般队列

1. 配置队列

创建一个配置类来定义队列：

import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class RabbitConfig {@Beanpublic Queue normalQueue() {return new Queue("normalQueue", true, false, false);}
}

这里创建了一个名为 normalQueue 的队列，true 表示队列持久化（消息在服务器重启后仍存在），第二个 false 表示非排他队列（多个消费者可以同时消费），第三个 false 表示自动删除（消息处理完后队列是否自动删除）。

2. 生产者发送消息

创建一个消息生产者类：

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class NormalQueueProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend("normalQueue", message);}
}

3. 消费者接收消息

创建一个消息消费者类：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;@Service
public class NormalQueueConsumer {@RabbitListener(queues = "normalQueue")public void receiveMessage(String message) {System.out.println("Received message from normalQueue: " + message);}
}

五、定义私信队列（Fanout Exchange）

1. 场景说明

假设有一个消息发布系统，需要将同一条消息广播给多个不同的接收方，例如新闻发布系统将一条新闻消息同时发送给多个订阅者，这种情况下就可以使用 Fanout Exchange （私信队列）。Fanout Exchange 会将接收到的消息广播到所有与之绑定的队列，而不考虑路由键。

2. 配置交换机和队列

import org.springframework.amqp.core.Binding;
import org.springframework.amqp.core.BindingBuilder;
import org.springframework.amqp.core.FanoutExchange;
import org.springframework.amqp.core.Queue;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class FanoutConfig {@Beanpublic Queue fanoutQueue1() {return new Queue("fanoutQueue1", true, false, false);}@Beanpublic Queue fanoutQueue2() {return new Queue("fanoutQueue2", true, false, false);}@Beanpublic FanoutExchange fanoutExchange() {return new FanoutExchange("fanoutExchange");}@Beanpublic Binding binding1(FanoutExchange fanoutExchange, Queue fanoutQueue1) {return BindingBuilder.bind(fanoutQueue1).to(fanoutExchange);}@Beanpublic Binding binding2(FanoutExchange fanoutExchange, Queue fanoutQueue2) {return BindingBuilder.bind(fanoutQueue2).to(fanoutExchange);}
}

这里创建了两个队列 fanoutQueue1 和 fanoutQueue2 ，并将它们绑定到一个 fanoutExchange 交换机上。Fanout Exchange 会将收到的消息广播到所有绑定的队列。

3. 生产者发送消息

import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class FanoutProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend("fanoutExchange", "", message);}
}

注意这里的路由键为空字符串，因为 Fanout Exchange 不需要路由键。

4. 消费者接收消息

分别创建两个消费者类来接收两个队列的消息，这里只展示一个示例：

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;@Service
public class FanoutQueue1Consumer {@RabbitListener(queues = "fanoutQueue1")public void receiveMessage(String message) {System.out.println("Received message from fanoutQueue1: " + message);}
}

六、定义延时队列

1. 场景说明

在很多业务场景中，需要对消息的发送进行延时处理。例如，在电商系统中，当用户下单后，如果用户在一定时间内没有支付，系统需要自动取消订单。这种情况下就可以使用延时队列来实现消息的延时发送和处理。

2. TTL + DLX方式（推荐）

2.1 配置死信交换机和队列
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;import java.util.HashMap;
import java.util.Map;@Configuration
public class DelayQueueConfig {// 定义延时队列@Beanpublic Queue delayQueue() {Map<String, Object> args = new HashMap<>();args.put("x-message-ttl", 5000); // 消息存活时间为5秒args.put("x-dead-letter-exchange", "delayDeadLetterExchange"); // 死信交换机args.put("x-dead-letter-routing-key", "delayDeadLetterQueue"); // 死信路由键return new Queue("delayQueue", true, false, false, args);}// 定义死信队列@Beanpublic Queue delayDeadLetterQueue() {return new Queue("delayDeadLetterQueue", true, false, false);}// 定义死信交换机@Beanpublic DirectExchange delayDeadLetterExchange() {return new DirectExchange("delayDeadLetterExchange");}// 绑定死信队列到死信交换机@Beanpublic Binding bindingDelayDeadLetter(Queue delayDeadLetterQueue, DirectExchange delayDeadLetterExchange) {return BindingBuilder.bind(delayDeadLetterQueue).to(delayDeadLetterExchange).with("delayDeadLetterQueue");}
}

这里创建了一个延时队列 delayQueue ，设置了消息存活时间为5秒，当消息过期后会转发到 delayDeadLetterExchange 交换机的 delayDeadLetterQueue 队列。下面详细解释一下各个参数的作用：
• x-message-ttl：表示消息在队列中的存活时间，单位是毫秒。当消息在队列中的存活时间超过这个值后，消息就会被标记为过期。
• x-dead-letter-exchange：指定死信交换机的名称。当消息过期后，会被发送到这个指定的交换机。
• x-dead-letter-routing-key：指定死信路由键。当消息过期后，会根据这个路由键将消息发送到死信交换机对应的队列。

2.2 生产者发送消息
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;@Service
public class DelayQueueProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message) {rabbitTemplate.convertAndSend("delayQueue", message);}
}
2.3 消费者接收消息
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;@Service
public class DelayDeadLetterQueueConsumer {@RabbitListener(queues = "delayDeadLetterQueue")public void receiveMessage(String message) {System.out.println("Received expired message from delayDeadLetterQueue: " + message);}
}

3. 使用RabbitMQ官方插件（需额外安装插件）

3.1 安装插件

• 下载插件：从RabbitMQ官方网站（https://www.rabbitmq.com/community-plugins.html ）下载 rabbitmq_delayed_message_exchange 插件。选择与你的RabbitMQ版本匹配的插件版本进行下载。
• 放置插件文件：将下载的插件文件（通常是一个 .ez 文件）复制到RabbitMQ服务器的插件目录下。在Ubuntu系统上，插件目录通常是 /usr/lib/rabbitmq/plugins/ 。如果没有该目录，可以创建它。
• 启用插件：安装完成后，需要启用插件。执行以下命令：
bash sudo rabbitmq-plugins enable rabbitmq_delayed_message_exchange
• 重启RabbitMQ服务：插件启用后，需要重启RabbitMQ服务使配置生效：
bash sudo systemctl restart rabbitmq-server

3.2 配置延时交换机和队列
import org.springframework.amqp.core.*;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;@Configuration
public class DelayedExchangeConfig {// 定义延时交换机@Beanpublic CustomExchange delayedExchange() {Map<String, Object> args = new HashMap<>();args.put("x-delayed-type", "direct"); // 延时消息类型，这里设置为directreturn new CustomExchange("delayedExchange", "x-delayed-message", true, false, args);}// 定义队列@Beanpublic Queue delayedQueue() {return new Queue("delayedQueue", true, false, false);}// 绑定队列到延时交换机@Beanpublic Binding bindingDelayedQueue(CustomExchange delayedExchange, Queue delayedQueue) {return BindingBuilder.bind(delayedQueue).to(delayedExchange).with("delayedRoutingKey").noargs();}
}

这里创建了一个名为 delayedExchange 的延时交换机，类型为 x-delayed-message ，并设置了 x-delayed-type 参数为 direct 。然后创建了一个队列 delayedQueue 并将其绑定到延时交换机上。

3.3 生产者发送消息
import org.springframework.amqp.rabbit.core.RabbitTemplate;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.amqp.support.converter.SimpleMessageConverter;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.messaging.support.MessageBuilder;
import org.springframework.stereotype.Service;import com.rabbitmq.client.MessageProperties;@Service
public class DelayedExchangeProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void sendMessage(String message, int delay) {MessageProperties messageProperties = new MessageProperties();messageProperties.setHeader("x-delay", delay); // 设置延时时间，单位为毫秒org.springframework.amqp.core.Message amqpMessage = new org.springframework.amqp.core.Message(message.getBytes(), messageProperties);rabbitTemplate.send("delayedExchange", "delayedRoutingKey", amqpMessage);}
}

在生产者发送消息时，通过设置消息头 x-delay 来指定消息的延时时间。

3.4 消费者接收消息
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Service;@Service
public class DelayedExchangeConsumer {@RabbitListener(queues = "delayedQueue")public void receiveMessage(String message) {System.out.println("Received delayed message from delayedQueue: " + message);}
}

七、总结

通过以上步骤，我们完成了RabbitMQ的安装以及与Spring Boot的整合，并实现了普通队列、私信队列和延时队列的定义和使用。在实际应用中，可以根据具体业务需求选择合适的消息模式和配置方式，以实现高效、可靠的消息传递和处理。同时，对于RabbitMQ的高级特性，如消息确认机制、消息持久化、集群配置等，可以根据实际情况进行深入学习和应用，以满足更复杂的业务场景。

http://www.dtcms.com/wzjs/116448.html

相关文章：

  • 高质量的中山网站建设肇庆网站制作软件
  • 淘宝内部卷网站建设网址提交入口
  • 做分销网站湖南网站设计外包费用
  • 宁夏建设工程造价站网站最近10个新闻
  • 有自媒体谁还做网站怎么优化网站
  • ppt免费背景图片seo百度点击软件
  • wordpress邮箱订阅关键词优化推广公司哪家好
  • 网页设计 大学生代做超级优化大师下载
  • wordpress手机博客seo公司后付费
  • 家居网站建设 百度文库网站查询域名解析
  • 玉林市网站建设河南新站关键词排名优化外包
  • 郴州网站seo百度收录查询api
  • 做网站经常加班还是app二级域名和一级域名优化难度
  • 做网站设计电脑买什么高端本好做关键词推广
  • 平面设计需要什么基础seo建设者
  • 给公司做网站的费用入什么科目百度推广客户端官方下载
  • 做网站教程视频百度提交网站收录查询
  • WordPress网站文章导出导入网络营销有哪些内容
  • 网站制度建设存在的问题中国疫情最新数据
  • 龙岩云支付推广长沙seo外包优化
  • 微网站建设市场分析沧州网站建设优化公司
  • 网站优化是在哪里做修改广州网络广告推广公司
  • 什么网站可以接设计方案从事网络销售都有哪些平台呢
  • 互联网网站制作重庆森林百度网盘
  • 做平面设计的一般浏览什么网站免费ip地址网站
  • 宁波做360网站推广正规代运营公司
  • mi2设计公司网站百度精准营销获客平台
  • 怎么用手机做网站百度手机快速排名点击软件
  • 风铃微网站怎么做石家庄seo推广
  • 重庆网站建设公司排名企业seo排名哪家好