农村网站建设茂名,千图网免费素材图库背景图片设计,网站制作客户资料,行政事业单位网站建设这里写目录标题 1.运行环境2.报错信息3.解决方案4.查看解决之后的效果 1.运行环境 使用docker运行了RabbitMQ的服务器#xff1a; 在idea中导入springAMQP的jar包#xff0c;分别编写了子模块生产者publisher#xff0c;消费者consumer#xff1a; 1.在publisher中运行测试… 这里写目录标题 1.运行环境2.报错信息3.解决方案4.查看解决之后的效果 1.运行环境 使用docker运行了RabbitMQ的服务器 在idea中导入springAMQP的jar包分别编写了子模块生产者publisher消费者consumer 1.在publisher中运行测试代码 2.在consumer中配置队列监听器并运行主类
2.报错信息
先运行consumer主类再运行publisher测试类查看队列信息的发送和接收
运行主类时出现了以下报错
3.解决方案
查看rabbitMQ是否存在该队列信息 在publisher中与MQ服务器建立连接创建对应队列即可 具体代码如下也就是官网中简单模型的hello world案例 当然主机名端口号账户密码这些需要根据实际情况修改 public class PublisherTest {Testpublic void testSendMessage() throws IOException, TimeoutException {// 1.建立连接ConnectionFactory factory new ConnectionFactory();// 1.1.设置连接参数分别是主机名、端口号、vhost、用户名、密码factory.setHost(192.168.61.141);factory.setPort(5672);factory.setVirtualHost(/);factory.setUsername(root);factory.setPassword(123456);// 1.2.建立连接Connection connection factory.newConnection();// 2.创建通道ChannelChannel channel connection.createChannel();// 3.创建队列String queueName simple.queue;channel.queueDeclare(queueName, false, false, false, null);// 4.发送消息String message hello, rabbitmq!;channel.basicPublish(, queueName, null, message.getBytes());System.out.println(发送消息成功【 message 】);// 5.关闭通道和连接channel.close();connection.close();}
}4.查看解决之后的效果
运行测试类 再次运行消费者主类
