RabbitMQ在Java中的完美实现:从入门到精通

简介: 本文由木头左介绍如何在Java项目中使用RabbitMQ。RabbitMQ是开源的AMQP实现,支持多种客户端,适合分布式系统中的消息传递。首先需安装Erlang和RabbitMQ,接着在Java项目中添加RabbitMQ客户端库依赖。通过创建连接工厂和连接,建立与RabbitMQ的通信,并展示了创建连接和通道的代码示例。

哈喽,大家好,我是木头左!

一、RabbitMQ简介

RabbitMQ是一个开源的AMQP实现,服务器端用Erlang语言编写,支持多种客户端,如:Python、Ruby、.NET、Java、JMS、C、PHP、ActionScript、XMPP、STOMP等,支持AJAX。用于在分布式系统中存储转发消息,在易用性、扩展性、高可用性等方面表现不俗。本文将详细介绍如何在Java项目中使用RabbitMQ。

二、环境搭建

2.1 安装Erlang

RabbitMQ是基于Erlang语言开发的,因此首先需要安装Erlang。请访问Erlang官网(https://www.erlang.org/downloads)下载并安装适合您操作系统的Erlang版本。

2.2 安装RabbitMQ

访问RabbitMQ官网(https://www.rabbitmq.com/download.html)下载并安装适合您操作系统的RabbitMQ版本。安装完成后,请确保RabbitMQ服务已启动。

三、Java项目中添加RabbitMQ依赖

在您的Java项目中,需要添加RabbitMQ Java客户端库的依赖。如果您使用的是Maven项目,请在pom.xml文件中添加以下依赖:

<dependency>
    <groupId>com.rabbitmq</groupId>
    <artifactId>amqp-client</artifactId>
    <version>5.13.0</version>
</dependency>

如果您使用的是Gradle项目,请在build.gradle文件中添加以下依赖:

implementation 'com.rabbitmq:amqp-client:5.13.0'

四、创建RabbitMQ连接工厂和连接

4.1 创建连接工厂

连接工厂是RabbitMQ中用于创建和管理连接的类。以下是创建连接工厂的方法:

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

public class RabbitMQConnectionFactory {
   
    private static final String HOST = "localhost";
    private static final int PORT = 5672;
    private static final String USERNAME = "guest";
    private static final String PASSWORD = "guest";

    public static Connection getConnection() throws Exception {
   
        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost(HOST);
        factory.setPort(PORT);
        factory.setUsername(USERNAME);
        factory.setPassword(PASSWORD);
        return factory.newConnection();
    }
}

4.2 创建连接和通道

连接是RabbitMQ中用于发送和接收消息的接口。以下是创建连接和通道的方法:

import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.ConnectionFactory;
import java.io.IOException;
import java.util.concurrent.TimeoutException;

public class RabbitMQChannel {
   
    private static final String QUEUE_NAME = "test_queue";
    private static final String EXCHANGE_NAME = "test_exchange";
    private static final String ROUTING_KEY = "test_routing_key";
    private static final int DELAY = 5000; // 延迟时间,单位:毫秒
    private static final boolean DURABLE = true; // 是否持久化消息,默认为true
    private static final boolean AUTO_ACKNOWLEDGE = true; // 是否自动确认消息,默认为true
    private static final boolean NON_BLOCKING = false; // 是否阻塞模式,默认为false(非阻塞)
    private static final int PRIORITY = 5; // 优先级,范围:0-9(0-5为普通优先级,4-9为加权优先级)
    private static final int TTL = 10; // 消息过期时间,单位:秒(0表示不过期)
    private static final boolean REQUEUE = false; // 是否重新入队消息,默认为false(不重新入队)
    private static final String CUSTOM_CONSUMER_TAG = "custom_consumer_tag"; // 自定义消费者标签,用于过滤消息,可选参数,默认为空字符串(不过滤)
    private static final String CUSTOM_PREFIXED_ROUTING_KEY = "custom_prefixed_routing_key"; // 自定义前缀路由键,用于过滤消息,可选参数,默认为空字符串(不过滤)
    private static final String[] CUSTOM_HEADERS = null; // 自定义头信息,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_DETAILS = null; // 自定义消息属性,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_APP_PROPERTIES = null; // 自定义应用属性,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_SEGMENT = null; // 自定义分段器名称,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_CONSUMER_GROUPS = null; // 自定义消费者组名称,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_RECEIVE_HANDLERS = null; // 自定义接收处理器名称,用于过滤消息,可选参数,默认为null(不过滤)
    private static final String[] CUSTOM_ACKNOWLEDGEMENT_HANDLERS = null; // 自定义确认处理器名称,用于过滤消息,可选参数,默认为null(不过滤)+
> 我是木头左,感谢各位童鞋的点赞、收藏,我们下期更精彩!
相关实践学习
消息队列RocketMQ版:基础消息收发功能体验
本实验场景介绍消息队列RocketMQ版的基础消息收发功能,涵盖实例创建、Topic、Group资源创建以及消息收发体验等基础功能模块。
消息队列 MNS 入门课程
1、消息队列MNS简介 本节课介绍消息队列的MNS的基础概念 2、消息队列MNS特性 本节课介绍消息队列的MNS的主要特性 3、MNS的最佳实践及场景应用 本节课介绍消息队列的MNS的最佳实践及场景应用案例 4、手把手系列:消息队列MNS实操讲 本节课介绍消息队列的MNS的实际操作演示 5、动手实验:基于MNS,0基础轻松构建 Web Client 本节课带您一起基于MNS,0基础轻松构建 Web Client
相关文章
|
6天前
|
传感器 数据采集 监控
Java串口编程入门
Java串口编程入门
|
10天前
|
消息中间件 Java Maven
如何在Java中使用RabbitMQ
如何在Java中使用RabbitMQ
|
15天前
|
设计模式 安全 Oracle
Java学习笔记:从入门到精通
Java学习笔记:从入门到精通
|
11天前
|
设计模式 Java 数据安全/隐私保护
Java中的设计模式:从入门到精通
Java中的设计模式:从入门到精通
|
13天前
|
Java API 网络安全
Java网络编程入门
Java网络编程入门
|
15天前
|
Java 数据处理 调度
Java多线程编程入门指南
Java多线程编程入门指南
|
15天前
|
传感器 数据采集 监控
Java串口编程入门
Java串口编程入门
|
14天前
|
Java API 网络安全
Java网络编程入门
Java网络编程入门
|
14天前
|
监控 Java API
Java Socket编程入门
Java Socket编程入门
|
9天前
|
消息中间件 负载均衡 Java
JAVA面试之MQ
JAVA面试之MQ
24 0