文章目录
- 一、代码
- 1、添加依赖
- 2、配置RabbitMQ连接
- 3、RabbitMQ配置
- 4、创建生产者
- 5、创建消费者
- 6、测试
- 二、遇到的问题
- 1、Channel shutdown
- 2、收不到信息
- 3、安装RabbitMQ,无法访问控制台访问
一、代码
1、添加依赖
在pom.xml文件中添加RabbitMQ的相关依赖
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-amqp</artifactId>
</dependency>
2、配置RabbitMQ连接
在application.properties文件中配置RabbitMQ的连接信息
spring.rabbitmq.host=your-rabbitmq-host
spring.rabbitmq.port=your-rabbitmq-port
spring.rabbitmq.username=your-rabbitmq-username
spring.rabbitmq.password=your-rabbitmq-password
其中,spring.rabbitmq.host和spring.rabbitmq.port是RabbitMQ服务器的地址和端口号,默认端口号为5672;spring.rabbitmq.username和spring.rabbitmq.password是登录RabbitMQ的用户名和密码,首次安装,默认账号和密码都为guest。
3、RabbitMQ配置
注:导入的包是org.springframework.amqp下面的
启动时,自动帮我们创建好Queue和Exchange,进行绑定
@Configuration
public class RabbitMQConfig {@Autowiredprivate ConnectionFactory connectionFactory;@Beanpublic RabbitAdmin rabbitAdmin() {return new RabbitAdmin(connectionFactory);}@Beanpublic Queue queue() {Queue queue = new Queue("forlan-queue");rabbitAdmin().declareQueue(queue);return queue;}@Beanpublic DirectExchange exchange() {DirectExchange exchange = new DirectExchange("forlan-exchange");rabbitAdmin().declareExchange(exchange);return exchange;}@Beanpublic Binding binding() {return BindingBuilder.bind(queue()).to(exchange()).with("forlan-routing-key");}
}
4、创建生产者
@Component
public class RabbitMQProducer {@Autowiredprivate RabbitTemplate rabbitTemplate;public void testSend(){rabbitTemplate.convertAndSend("forlan-exchange", "forlan-routing-key", "测试发送RabbitMQ");}
}
其中,RabbitTemplate是Spring AMQP库提供的一个类,用于操作RabbitMQ队列;convertAndSend方法用于将消息对象转换成RabbitMQ的消息格式,并通过指定的交换机和路由键将消息发送到指定的队列中,在这里,我们使用了"forlan-exchange和"forlan-routing-key"作为交换机和路由键的名称。
5、创建消费者
@Component
public class RabbitMQConsumer {@RabbitListener(queues = "forlan-queue")public void handleMessage(String message) {System.out.println("RabbitMQConsumer收到消息:" + message);}
}
@RabbitListener 是Spring框架为简化RabbitMQ消息监听而提供的一个注解。通过在方法上添加此注解,Spring会将该方法注册为一个消息监听器,当RabbitMQ队列中有消息到达时,会自动调用该方法进行处理。也就是当RabbitMQ中的 “forlan-queue” 队列中有新的消息到达时,就会自动调用 handleMessage 方法进行处理。
6、测试
@Autowired
private RabbitMQProducer rabbitMQProducer;
@Test
public void send() {rabbitMQProducer.testSend("Forlan测试发送RabbitMQ消息");
}
消费者成功收到信息
二、遇到的问题
1、Channel shutdown
Channel shutdown: channel error; protocol method: #method<channel.close>(reply-code=404, reply-text=NOT_FOUND - no exchange 'forlan-exchange' in vhost '/', class-id=60, method-id=40)
不存在的,不会自动帮你创建,你可以在RabbitMQ后台创建,也可以在代码中设置不存在时创建,项目中就是采取在代码中自动创建了
2、收不到信息
因为RabbitMQConsumer没有注入到容器中,记得加上@Component,如下:
@Component
public class RabbitMQConsumer {...
}
3、安装RabbitMQ,无法访问控制台访问
需要开放控制台远程登录权限,在安装的目录/etc/rabbitmq下配置好rabbitmq.config,内容如下:
[{rabbit,[{loopback_users,[]}]}].
注:记得配置不要有多余的标点符号,不然会出现Failed to start RabbitMQ broker.