已解决
Java中配置RabbitMQ基本步骤
来自网友在路上 147847提问 提问时间:2023-10-25 05:51:35阅读次数: 47
最佳答案 问答题库478位专家为你答疑解惑
在Java中配置RabbitMQ,需要遵循以下步骤:
1.添加依赖
在项目的pom.xml文件中添加RabbitMQ的Java客户端依赖:
<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>5.13.0</version>
</dependency>
2.创建连接工厂
创建一个连接工厂,用于创建与RabbitMQ服务器的连接:
import com.rabbitmq.client.ConnectionFactory;public class RabbitMQConfig {public static ConnectionFactory createConnectionFactory() {ConnectionFactory factory = new ConnectionFactory();factory.setHost("localhost"); // 设置RabbitMQ服务器地址factory.setPort(5672); // 设置RabbitMQ服务器端口factory.setUsername("guest"); // 设置用户名factory.setPassword("guest"); // 设置密码return factory;}
}
3.创建生产者和消费者
创建一个生产者,用于发送消息到RabbitMQ队列:
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;public class Producer {public static void main(String[] args) throws Exception {ConnectionFactory factory = RabbitMQConfig.createConnectionFactory();Connection connection = factory.newConnection();Channel channel = connection.createChannel();String queueName = "test_queue";channel.queueDeclare(queueName, false, false, false, null);String message = "Hello, RabbitMQ!";channel.basicPublish("", queueName, null, message.getBytes("UTF-8"));System.out.println("Sent: '" + message + "'");channel.close();connection.close();}
}
创建一个消费者,用于从RabbitMQ队列中接收消息:4
import com.rabbitmq.client.*;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class Consumer {public static void main(String[] args) throws IOException, TimeoutException {ConnectionFactory factory = RabbitMQConfig.createConnectionFactory();Connection connection = factory.newConnection();Channel channel = connection.createChannel();String queueName = "test_queue";channel.queueDeclare(queueName, false, false, false, null);System.out.println("Waiting for messages...");DeliverCallback deliverCallback = (consumerTag, delivery) -> {String message = new String(delivery.getBody(), "UTF-8");System.out.println("Received: '" + message + "'");};channel.basicConsume(queueName, true, deliverCallback, consumerTag -> {});}
}
4.运行生产者和消费者
分别运行Producer和Consumer类的main方法,生产者将消息发送到RabbitMQ队列,消费者将从队列中接收并处理消息。
查看全文
99%的人还看了
相似问题
- rabbitMQ的扇出模式(fanout发布订阅)的生产者与消费者使用案例
- Java编写简易rabbitmq生产者与消费者
- SpringBoot Kafka生产者 多kafka配置
- linux入门---消费者生产者模型模拟实现
- java经典例题:生产者/消费者问题
- RocketMQ生产者消息发送出去了,消费者一直接收不到怎么办?(Rocket MQ订阅关系一致性)
- <多线程章节九>生产者消费者模型,阻塞队列的使用和模拟实现
- Spring Kafka生产者实现
- Sentinel学习(2)——sentinel的使用,引入依赖和配置 对消费者进行流控 对生产者进行熔断降级
- 【Linux】生产者和消费者模型
猜你感兴趣
版权申明
本文"Java中配置RabbitMQ基本步骤":http://eshow365.cn/6-23958-0.html 内容来自互联网,请自行判断内容的正确性。如有侵权请联系我们,立即删除!