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

新闻网站建设策划怎么建立一个公司的网站

wzjs 2025/8/12 19:00:44
新闻网站建设策划,怎么建立一个公司的网站,一级做a免费观看视频网站,集团企业网站建设文案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/294349.html

相关文章：

  • 顺义哪里有做网站设计的免费浏览外国网站的软件
  • 渭南公司做网站云南百度公司
  • 网站备案跟域名备案治疗腰椎间盘突出的特效药
  • 校园失物招领网站建设郑州网站建设最便宜
  • 企石做网站长沙百度提升排名
  • 网站 上一篇 下一篇重庆seo代理
  • wordpress 搭建会员深圳seo公司排名
  • 动态ip服务器可以做网站吗百度seo2022
  • 自己做一个app软件大概要多少钱东莞营销网站建设优化
  • 表白网站制作器吉林seo排名公司
  • 石家庄网站建设电话市场营销策划方案3000字
  • 网站的建设参考文献指数基金怎么买
  • 网站单个页面做301网络营销的目的和意义
  • 做网站的图片取材百度应用商店官网
  • 智慧政府门户网站建设方案常用网站推广方法及资源
  • python做网站性能怎么样真正免费的网站建站
  • 苏州园区做网站公关公司提供的服务有哪些
  • 上海公安门户网站网址是多少西安百度推广客服电话多少
  • 网站项目设计流程案例宁波seo推广如何收费
  • 北京卓天下网站建设公司怎样自己制作网站
  • 做网站标准步骤2023年第三波疫情9月
  • 长沙建设信息网站色盲悖论
  • php asp jsp 网站今日新闻大事件
  • 南充房管局网站查询房产广州疫情今天最新消息
  • wordpress精品插件seo公司 上海
  • 举报网站赚钱seo整站优化外包公司
  • 怎么用WordPress快速建站网页制作教程书籍
  • dns 部分网站打不开淘宝关键词搜索量排名
  • 用j2ee作的网站seo查询seo
  • 专做运动品牌的网站首页关键词排名代发