首页 > 编程语言 >RabbitMQ在Java中的完美实现:从入门到精通

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

时间:2024-05-19 19:30:41浏览次数:30  
标签:Java 入门 private static RabbitMQ null final String

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

一、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(不过滤)+
> 我是木头左,感谢各位童鞋的点赞、收藏,我们下期更精彩!
    

标签:Java,入门,private,static,RabbitMQ,null,final,String
From: https://www.cnblogs.com/bigleft/p/18200610

相关文章

  • net.sf.jsqlparser.schema.Column.withColumnName(Ljava/lang/String;)Lnet/sf/jsqlpar
    https://blog.csdn.net/yuanzhugen/article/details/133648431 SpringBoot整合mybatisplus报错:net.sf.jsqlparser.schema.Column,isavailablefromthefollowinglocationsAnattemptwasmadetocallthemethodnet.sf.jsqlparser.schema.Column.withColumnName(Ljava/l......
  • 使用javap -v 命令遇到的问题
    今天在学习jvm的时候,在使用javap-v查看编译后的class文件的信息的时候,遇到了LocalVariableTable项显示不全的问题。经过排查后才发现,原来是自己本机配置的jdk环境是java11的,于是将环境退回到jdk8,再次执行javap-v命令就看到了自己想要的结果了。这里还有一点需要注意的是,......
  • java+mybatis+easyExcel快速导入excel数据到MySQL
    这里有一些数据需要导入数据库。demo地址:importExcel使用步骤如下:一、修改database相关内容 1.修改application.properties文件中数据库地址及信息二、新建实体类1.新建excel数据所符合的实体类,这里举例Excel中有如下数据,表头字段为“username”。数据......
  • JavaScript Promise Time Limit Function All In One
    JavaScriptPromiseTimeLimitFunctionAllInOneLeetCode2637.PromiseTimeLimiterrorsfunctiontimeLimit(fn:Fn,t:number):Fn{returnasyncfunction(...args){//letbegin=Date.now();letbegin=performance.now();letresult=......
  • C语言编程题练习 (从初识到入门再到进阶)修正版
    C语言编程题练习......
  • HTML 28 - Javascript
    Ascriptisasmallpieceofprogramthatcanaddinteractivitytoourwebsites.Forexample,ascriptcouldgenerateapop-upalertboxmessage,orprovideadropdownmenu.ThisscriptcouldbewrittenusingJavaScriptorVBScript.Nowadays,onlyJavaScr......
  • [转帖]【全网首发】一些可以显著提高 Java 启动速度方法原创
    https://heapdump.cn/article/4136322?from=pc 我们线上的业务jar包基本上普遍比较庞大,动不动一个jar包上百M,启动时间在分钟级,拖慢了我们在故障时快速扩容的响应。于是做了一些分析,看看Java程序启动慢到底慢在哪里,如何去优化,目前的效果是大部分大型应用启动时间可......
  • Java(7)-Maven抽取公共模块构建jar包
    前提假设:项目中有两个Moudle,分别是Moudle1和Moudle2,它们有些代码是相同的,比如相同的类和API,重复书写当然可以正常运行,但是我们可以用maven打包成jar包,其他Moudle直接引用即可。步骤1.新建一个Module-commonpox.xml中配置Module1和Moudle2同样使用的依赖:<dependencies......
  • Django测试与持续集成:从入门到精通
    title:Django测试与持续集成:从入门到精通date:2024/5/1816:38:41updated:2024/5/1816:38:41categories:后端开发tags:Django测试CI/CD优化部署监控迭代第1章:Django测试基础1.1Django测试框架概述Django测试框架是Djangoweb框架的一部分,提供了一个强......
  • 关于cmd运行javac提示'javac' 不是内部或外部命令,也不是可运行的程序的问题
     大家可以看到我这边cmd运行javac命令,它对我进行了错误的提示,提示javac不是可运行命令和程序。这个问题的根本在于环境变量的配置出现了错误。接下来就要进行jdk的环境配置了。  注意点:这里要定位到自身存放jdk的bin目录才会生效。  点击确定即可,然后打开cmd窗口......