RabbitMq的Java项目实践

news2025/1/7 4:02:56

        在现代软件开发中,消息队列(Message Queue,简称MQ)作为一种重要的组件,承担着上下游消息传递和通信的重任。RabbitMQ作为一款流行的开源消息队列中间件,凭借其高可用性、可扩展性和易用性等特点,在Java项目中得到了广泛的应用。本文将详细介绍RabbitMQ的基本概念、在Java项目中的实践应用,并通过示例代码展示如何使用RabbitMQ进行消息的发送和接收。

 

一、RabbitMQ的基本概念

        RabbitMQ是一个开源的AMQP(Advanced Message Queuing Protocol,高级消息队列协议)实现,服务器端用Erlang语言编写,支持多种客户端,如Python、Ruby、.NET、Java等。它用于在分布式系统中存储和转发消息,具有高可用性、高可扩性、易用性等特征。

        RabbitMQ的核心组件包括:

  • Message:消息,是不具名的,由消息头和消息体组成。
  • Publisher:消息的生产者,是一个向交换器发布消息的客户端应用程序。
  • Exchange:交换器,用来接收生产者发送的消息,并将这些消息路由给服务器中的队列。Exchange有四种类型:direct(默认)、fanout、topic和headers,不同类型的Exchange转发消息的策略有所区别。
  • Queue:消息队列,用来保存消息直到发送给消费者。它是消息的容器,也是消息的终点。一个消息可以投入一个或多个队列。
  • Binding:绑定,用于消息队列和交换器之间的关联。一个绑定就是基于路由键将交换器和消息队列连接起来的路由规则。
  • Connection:网络连接,如TCP连接。
  • Channel:信道,是多路复用连接中的一条独立的双向数据流通道。信道建立在真实的TCP连接内,AMQP命令都是通过信道发出去的。
  • Consumer:消息的消费者,是一个从消息队列中取得消息的客户端应用程序。
  • Virtual Host:虚拟主机,表示一批交换器、消息队列和相关对象。出于多租户和安全因素设计,将AMQP的基本组件划分到一个虚拟的分组中。
  • Broker:消息队列服务器实体,接收和分发消息的应用。RabbitMQ Server就是Message Broker。
二、RabbitMQ在Java项目中的应用

        在Java项目中,RabbitMQ可以作为消息中间件,用于实现异步通信、解耦服务、流量削峰等应用场景。以下是一个详细的实践指南,包括安装RabbitMQ、配置Java项目、发送和接收消息的示例代码。

1. 安装RabbitMQ

        首先,需要在本地或远程服务器上安装RabbitMQ。可以从RabbitMQ官网下载并安装。安装完成后,可以使用以下命令启动RabbitMQ服务:

sudo rabbitmq-server start

        为了便于管理,可以启用RabbitMQ管理插件:

sudo rabbitmq-plugins enable rabbitmq_management

        然后在浏览器中访问http://localhost:15672来访问管理界面,默认的用户名和密码为guest。

2. 配置Java项目

        在Java项目中,需要引入RabbitMQ的Java客户端库。可以通过Maven来管理项目依赖。在pom.xml文件中添加以下依赖:

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.15.0</version>
</dependency>
3. 发送消息

        以下是一个简单的Java程序,用于发送消息到RabbitMQ队列:

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;

public class Send {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            String message = "Hello World!";
            channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
            System.out.println(" [x] Sent '" + message + "'");
        }
    }
}

        在上面的代码中,首先创建了一个ConnectionFactory对象,并设置了RabbitMQ服务器的地址。然后,使用factory.newConnection()方法创建一个连接对象,并使用connection.createChannel()方法创建一个通道对象。接下来,使用channel.queueDeclare()方法声明一个队列。最后,使用channel.basicPublish()方法将消息发送到指定的队列中。

4. 接收消息

        接收消息的Java程序如下所示:

import com.rabbitmq.client.*;

public class Recv {
    private final static String QUEUE_NAME = "hello";

    public static void main(String[] argv) throws Exception {
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("localhost");
        try (Connection connection = factory.newConnection(); Channel channel = connection.createChannel()) {
            channel.queueDeclare(QUEUE_NAME, false, false, false, null);
            System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
            DeliverCallback deliverCallback = (consumerTag, delivery) -> {
                String message = new String(delivery.getBody(), "UTF-8");
                System.out.println(" [x] Received '" + message + "'");
            };
            channel.basicConsume(QUEUE_NAME, true, deliverCallback, consumerTag -> {});
        }
    }
}

        在上面的代码中,同样首先创建了一个ConnectionFactory对象,并设置了RabbitMQ服务器的地址。然后,使用factory.newConnection()方法创建一个连接对象,并使用connection.createChannel()方法创建一个通道对象。接下来,使用channel.queueDeclare()方法声明一个队列(注意:这里声明的队列名称应该与发送消息时使用的队列名称一致)。最后,使用channel.basicConsume()方法注册一个回调函数来处理接收到的消息。当消息到达队列时,回调函数会被触发,并打印出接收到的消息内容。

三、RabbitMQ的高级特性与应用场景

        除了基本的发送和接收消息功能外,RabbitMQ还支持许多高级特性,如消息持久化、发布/订阅模式、路由键匹配、死信队列等。这些特性使得RabbitMQ可以应用于更加复杂的场景中。

  • 消息持久化

为了确保消息在RabbitMQ服务器重启后不会丢失,可以将消息设置为持久化模式。这需要在发送消息时设置deliveryMode属性为2,并在创建队列时设置队列的持久化属性为true。

  • 发布/订阅模式

RabbitMQ支持发布/订阅模式,允许多个消费者订阅同一个队列并接收消息。这可以通过将消息发送到交换器,并绑定多个队列到该交换器来实现。

  • 路由键匹配

RabbitMQ支持基于路由键的匹配规则来将消息路由到不同的队列中。这可以通过设置交换器的类型和绑定键来实现。

  • 死信队列

死信队列用于处理无法被正常消费的消息。当消息被拒绝或达到最大重试次数时,可以将消息路由到死信队列中进行处理。

总结

        RabbitMQ作为一款功能强大的消息队列中间件,在Java项目中得到了广泛的应用。通过引入RabbitMQ的Java客户端库,并编写简单的发送和接收消息的代码,可以轻松实现异步通信、解耦服务、流量削峰等应用场景。同时,RabbitMQ还支持许多高级特性,如消息持久化、发布/订阅模式、路由键匹配、死信队列等,这些特性使得RabbitMQ可以应用于更加复杂的场景中。了解和使用RabbitMQ,对于提升系统的性能和可靠性具有重要意义。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2271323.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

CK40N或CK24标准成本发布出现标记不到物料的情况:评估视图中允许的成本核算变式选择错误

用户打电话反馈标准成本发布在标记环节出现错误&#xff1a; 检查&#xff1a; 1、MM03已经维护了税价1。 2、CK13N&#xff1a; 没有成本没本滚算。 用户是用CK40N处理的&#xff0c; 我让他用CK11N/CK24再处理一次。 仍然报错. 我也试了一个也是报错。 准备CRK1删除原来的…

【HENU】河南大学计院2024 计算机体系结构 期末复习知识点

和光同尘_我的个人主页 一直游到海水变蓝。 体系结构 第一章&#xff1a;计算机系统基础知识计算机系统的实质计算机系统的设计的4个定量原理Amdahl定律CPU性能公式程序的局部性原理: 第二章&#xff1a;指令系统的设计指令系统结构的分类通用寄存器型结构 哈夫曼编码MIPS指令…

Docker 远程访问完整配置教程以及核心参数理解

Docker 远程访问完整配置教程 以下是配置 Docker 支持远程访问的完整教程&#xff0c;包括参数说明、配置修改、云服务器安全组设置、主机防火墙配置&#xff0c;以及验证远程访问的详细步骤。 1. 理解 -H fd:// 参数的作用&#xff08;理解了以后容易理解后面的操作&#xff…

如何在不丢失数据的情况下从 IOS 14 回滚到 IOS 13

您是否后悔在 iPhone、iPad 或 iPod touch 上安装 iOS 14&#xff1f;如果你这样做&#xff0c;你并不孤单。许多升级到 iOS 14 beta 的 iPhone、iPad 和 iPod touch 用户不再适应它。 如果您在正式发布日期之前升级到 iOS 14 以享受其功能&#xff0c;但您不再适应 iOS 14&am…

vue3 css实现文字输出带光标显示,文字输出完毕,光标消失的效果

Vue实现过程如下&#xff1a; <template><div ><p ref"dom_element" class"typing" :class"{over_fill: record_input_over}"></p></div> </template> <script setup> import {onMounted, ref} from…

Postman测试big-event

报错500。看弹幕&#xff0c;知道可能是yml或sql有问题。 所以检查idea工作台&#xff0c; 直接找UserMapper检查&#xff0c;发现完全OK。 顺着这个error发现可能是sql有问题。因为提示是sql问题&#xff0c;而且是有now()的那个sql。 之后通过给的课件&#xff0c;复制课件…

Wonder Dynamics技术浅析(八):实拍与虚拟合成

该模块旨在将实拍视频与计算机生成的虚拟场景无缝融合&#xff0c;生成具有高度真实感的视觉效果。 一、实拍视频与虚拟场景合成概述 实拍视频与虚拟场景合成的主要目标是将实拍视频中的元素与计算机生成的虚拟场景进行无缝融合&#xff0c;生成具有高度真实感的最终影像。 …

Javascript算法——回溯算法(子集和全排列问题)

子集问题 思路 如果把 子集问题、组合问题、分割问题都抽象为一棵树的话&#xff0c;那么组合问题和分割问题都是收集树的叶子节点&#xff0c;而子集问题是找树的所有节点&#xff01; 78.子集 相比组合问题&#xff0c;此子集问题题目更为简单&#xff0c;收集的是树的所有…

网络安全系统学习实验1:RDP远程登录配置

准备工作&#xff1a; 0、准备好虚拟机 1、服务器侧&#xff08;虚拟机Windows 2003-01&#xff09;IP地址&#xff1a; # 获得服务器的IP地址192.168.58.223 ipconfig /all2、客户端侧(虚拟机Win7 pte_czj)IP地址&#xff1a; # 客户端侧IP地址192.168.58.222 ipconfig /al…

SMMU软件指南之系统架构考虑

安全之安全(security)博客目录导读 目录 5.1 I/O 一致性 5.2 客户端设备 5.2.1 地址大小 5.2.2 缓存 5.3 PCIe 注意事项 5.3.1 点对点通信 5.3.2 No_snoop 5.3.3 ATS 5.4 StreamID 分配 5.5 MSI 本博客介绍与 SMMU 相关的一些系统架构注意事项。 5.1 I/O 一致性 如…

[网络安全]sqli-labs Less-3 解题详析

判断注入类型 GET1 and 11&#xff0c;回显如下&#xff1a;GET1 and 12&#xff1a;没有回显&#xff0c;说明该漏洞类型为GET型单引号字符型注入 判断注入点个数 GET1 order by 2 --&#xff0c;回显如下&#xff1a;由上图可知&#xff0c;sql语法中给$id加上了() 猜测后…

vulnhub Earth靶机

搭建靶机直接拖进来就行 1.扫描靶机IP arp-scan -l 2.信息收集 nmap -sS -A -T4 192.168.47.132 得到两个DNS; 在443端口处会让我们加https dirb https://earth.local/ dirb https://terratest.earth.local/ #页面下有三行数值 37090b59030f11060b0a1b4e0000000000004312170a…

AWS 申请证书、配置load balancer、配置域名

申请AWS证书 点击 request 申请完证书&#xff0c;AWS 会验证你对于域名的所有权&#xff0c;有两种方式&#xff0c;DSN 验证和邮箱验证。 这里说一下DSN 验证&#xff0c;上图中 Domains 中有CNAME name 和 CNAME value 。 在domain 网站中添加一个CNAME DSN 项&#xff0c;…

【WPF】 数据绑定机制之INotifyPropertyChanged

INotifyPropertyChanged 是 WPF 中的一个接口&#xff0c;用于实现 数据绑定 中的 属性更改通知。它的主要作用是&#xff0c;当对象的某个属性值发生更改时&#xff0c;通知绑定到该属性的 UI 控件更新其显示内容。 以下是有关 INotifyPropertyChanged 的详细信息和实现方法&…

基于Spring Boot的IT技术交流和分享平台的设计与实现源码

风定落花生&#xff0c;歌声逐流水&#xff0c;大家好我是风歌&#xff0c;混迹在java圈的辛苦码农。今天要和大家聊的是一款基于springboot的IT技术交流和分享平台的设计与实现。项目源码以及部署相关请联系风歌&#xff0c;文末附上联系信息 。 项目简介&#xff1a; 基于S…

齿轮缺陷检测数据集VOC+YOLO格式485张3类别

数据集格式&#xff1a;Pascal VOC格式YOLO格式(不包含分割路径的txt文件&#xff0c;仅仅包含jpg图片以及对应的VOC格式xml文件和yolo格式txt文件) 图片数量(jpg文件个数)&#xff1a;485 标注数量(xml文件个数)&#xff1a;485 标注数量(txt文件个数)&#xff1a;485 标注…

Airflow:HttpSensor实现API驱动数据流程

数据管道工作流通常依赖于api来访问、获取和处理来自外部系统的数据。为了处理这些场景&#xff0c;Apache Airflow提供了HttpSensor&#xff0c;这是一个内置的Sensor&#xff0c;用于监视HTTP请求的状态&#xff0c;并在满足指定条件时触发后续任务。在这篇博文中&#xff0c…

活动预告 | Microsoft Power Platform 在线技术公开课:实现业务流程自动化

课程介绍 参加“Microsoft Power Platform 在线技术公开课&#xff1a;实现业务流程自动化”活动&#xff0c;了解如何更高效地开展业务。参加我们举办的本次免费培训活动&#xff0c;了解如何借助 Microsoft AI Builder 和 Power Automate 优化工作流。结合使用这些工具可以帮…

【SpringBoot教程】搭建SpringBoot项目之编写pom.xml

&#x1f64b;大家好&#xff01;我是毛毛张! &#x1f308;个人首页&#xff1a; 神马都会亿点点的毛毛张 &#x1f44f;今天毛毛张分享的内容主要是Maven 中 pom 文件&#x1f195;&#xff0c;涵盖基本概念、标签属性、配置等内容 文章目录 1.前言&#x1f96d;2.项目基本…

职场常用Excel基础04-二维表转换

大家好&#xff0c;今天和大家一起分享一下excel的二维表转换相关内容~ 在Excel中&#xff0c;二维表&#xff08;也称为矩阵或表格&#xff09;是一种组织数据的方式&#xff0c;其中数据按照行和列的格式进行排列。然而&#xff0c;在实际的数据分析过程中&#xff0c;我们常…