com.rabbitmq.client.AuthenticationFailureException: ACCESS

public class Procuder {public static void main(String[] args) throws Exception {//1 创建一个ConnectionFactory, 并进行配置ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("localhost");
//      connectionFactory.setHost("192.168.43.223");connectionFactory.setPort(5672);connectionFactory.setVirtualHost("/");connectionFactory.setUsername("guest");connectionFactory.setPassword("guest");//2 通过连接工厂创建连接Connection connection = connectionFactory.newConnection();//3 通过connection创建一个ChannelChannel channel = connection.createChannel();//4 通过Channel发送数据for(int i=0; i < 5; i++){String msg = "Hello RabbitMQ!";//1 exchange   2 routingKeychannel.basicPublish("", "test001", null, msg.getBytes());}//5 记得要关闭相关的连接channel.close();connection.close();}
}

public class Consumer {public static void main(String[] args) throws Exception {//1 创建一个ConnectionFactory, 并进行配置ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("localhost");
//      connectionFactory.setHost("192.168.43.223");connectionFactory.setPort(5672);connectionFactory.setVirtualHost("/");connectionFactory.setUsername("guest");connectionFactory.setPassword("guest");//2 通过连接工厂创建连接Connection connection = connectionFactory.newConnection();//3 通过connection创建一个ChannelChannel channel = connection.createChannel();//4 声明（创建）一个队列String queueName = "test001";channel.queueDeclare(queueName, true, false, false, null);//5 创建消费者QueueingConsumer queueingConsumer = new QueueingConsumer(channel);//6 设置Channelchannel.basicConsume(queueName, true, queueingConsumer);while(true){//7 获取消息Delivery delivery = queueingConsumer.nextDelivery();String msg = new String(delivery.getBody());System.err.println("消费端: " + msg);//Envelope envelope = delivery.getEnvelope();}}
}

原因：

解决：

connectionFactory.setHost("localhost"); 本质原因还没追

原因可能是
https://www.cnblogs.com/tjudzj/p/9223748.html

com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED相关推荐

Amqp整合com.rabbitmq.client.ShutdownSignalException: channel error； protocol method异常处理
Amqp整合com.rabbitmq.client.ShutdownSignalException: channel error; protocol method异常处理参考文章: (1)Amqp整 ...
【默认加入持久化机制，防止消息丢失，v0.0.3】对RabbitMQ.Client进行一下小小的包装，绝对实用方便...
RabbitMQ是一个老牌的非微软的消息队列组件,一般来说应该能满足中小型公司对消息队列生产的需求,平时我们在.NET开发环境下运用它是可能会需要RabbitMQ.Client的SDK库,此库是官网提 ...
已解决：ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error
ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler - An unexpected connection driver error occ ...
Mq报错：Caused by: com.rabbitmq.client.ShutdownSignalException
详细报错信息: 这里可以看见: connection error; protocol method: #method<connection.close>(reply-code=530, r ...
【RabbitMQ】连接RabbitMQ异常： com.rabbitmq.client.ShutdownSignalException: connection error； protocol meth
测试该工具类: package com.wj.utils; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Conn ...
RabbitMq无法连接([AMQP Connection xx.xx.xx.xx:5672-119] ERROR com.rabbitmq.client.impl.ForgivingExcept)
报错信息 [AMQP Connection xx.xx.xx.xx:5672-119] ERROR com.rabbitmq.client.impl.ForgivingExceptionHandler ...
RabbitMQ.Client.TopologyRecoveryException问题与解决
封装了一下RabbitMQ驱动的调用,扔给团队用,一直也没出现啥问题, 昨天同事突然反馈给我,说调试时一直报错: Topology recovery exception: RabbitMQ.Clien ...
RabbitMQ异常：ACCESS_REFUSED - Login was refused using authentication mechanism PLAIN.
生命无罪,健康万岁,我是laity. 我曾七次鄙视自己的灵魂: 第一次,当它本可进取时,却故作谦卑: 第二次,当它在空虚时,用爱欲来填充: 第三次,在困难和容易之间,它选择了容易: 第四次,它犯了错, ...
【异常报错】com.rabbitmq.client.ShutdownSignalException: channel error； protocol method: #method＜channel.c
在IDEA中,RabbitMQ启动的时候控制台报上面的错误: 我的解决办法是: 将之前生成的target文件删除,重新启动,然后不报错了

com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED

com.rabbitmq.client.AuthenticationFailureException: ACCESS_REFUSED相关推荐

最新文章

热门文章