详细报错信息：

这里可以看见： connection error; protocol method: #method<connection.close>(reply-code=530, reply-text=NOT_ALLOWED - access to vhost '/' refused for user 'admin', class-id=10, method-id=40)

我在这里是写了一个简单的试例。也就是simple模式

代码如下

package lanlan.Simple;import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;import java.io.IOException;
import java.util.concurrent.TimeoutException;public class sheng {//所有中间键技术都是基于tcp/ip协议之上来构建，只不过rabbitma是遵循ampq协议public static void main(String[] args) throws IOException, TimeoutException {//1:创建连接工程ConnectionFactory connectionFactory = new ConnectionFactory();connectionFactory.setHost("101.35.114.14");connectionFactory.setPort(5672);connectionFactory.setUsername("admin");connectionFactory.setPassword("admin");connectionFactory.setVirtualHost("/");//为下面提供对象Connection connection = null;Channel channel = null;try{//2：创建连接connnctionconnection = connectionFactory.newConnection("客户端看见的消息");//3:通过连接获取通道channel = connection.createChannel();//4:通过创建交换机，声明队列。绑定关系。路由key，发送消息，和接收消息String queueName = "queuejin";/*参数1：队列名称参数2：是否持久化，参数3：排他性，是否独占独立参数4：是否自动删除，一般不自动删除参数5：携带参数，后面有用到* */channel.queueDeclare(queueName,false,false,false,null);//5：准备消息内容String message ="jinzhng！！！！";//6:发送出去给队列channel.basicPublish("",queueName,null,message.getBytes());System.err.println("发送消息成功");} catch (IOException | TimeoutException e) {e.printStackTrace();} finally {//7:关闭通道if (channel!=null&& channel.isOpen()){channel.close();}//8:关闭连接if (connection !=null && connection.isOpen()){connection.close();}}}
}

解决方法：可以看见我是使用admin去登录的mq的管理但是这里我的admin其实是没有管理权限的

Mq报错：Caused by: com.rabbitmq.client.ShutdownSignalException相关推荐

【RabbitMQ】连接RabbitMQ异常： com.rabbitmq.client.ShutdownSignalException: connection error； protocol meth
测试该工具类: package com.wj.utils; import com.rabbitmq.client.Connection; import com.rabbitmq.client.Conn ...
启动tomcat报错Caused by: org.apache.catalina.LifecycleException: No UserDatabase component
启动tomcat报错 Caused by: org.apache.catalina.LifecycleException: No UserDatabase component 替换conf/tomca ...
详解：hive启动hiveserver2连JDBC报错：Could not open client transport with JDBC Uri 解决方案
hive启动hiveserver2连JDBC报错:Could not open client transport with JDBC Uri 解决方案 [hadoop@hadoop001 bin]$ ...
Maven项目报错:Caused by: java.lang.NoClassDefFoundError: com/fasterxml/classmate/Filter
一.问题描述项目一运行就报错: Caused by: java.lang.NoClassDefFoundError: com/fasterxml/classmate/Filterat org.hib ...
MQ报错2009/2085解决方法
MQ报错2009/2085解决方法参考文章: (1)MQ报错2009/2085解决方法 (2)https://www.cnblogs.com/zwh-Seeking/p/12023813.html ...
Conda更新报错:requests.exceptions.HTTPError: 404 Client Error: Not Found for url: https://mirrors.tuna.t
Conda更新报错:requests.exceptions.HTTPError: 404 Client Error: Not Found for url: https://mirrors.tuna.t ...
Amqp整合com.rabbitmq.client.ShutdownSignalException: channel error； protocol method异常处理
Amqp整合com.rabbitmq.client.ShutdownSignalException: channel error; protocol method异常处理参考文章: (1)Amqp整 ...
Java mq 2059_Java连接MQ报错，通道协商失败 MQJE001: 完成代码为“2”，原因为“2059...
我也曾经遇到过这个错误,当时队列管理器,队列,通道都一一创建,但就是报错 HostName=192.168.8.46 Channel=CH1 QManager=WNMS3_QM MQJE001: 完成 ...
Java mq 2059_Java连接MQ报错，通道协商失败 MQJE001: 完成代码为“2”，原因为“2059 | 学步园...
我也曾经遇到过这个错误,当时队列管理器,队列,通道都一一创建,但就是报错 HostName=192.168.8.46 Channel=CH1 QManager=WNMS3_QM MQJE001: 完成 ...

Mq报错：Caused by: com.rabbitmq.client.ShutdownSignalException

详细报错信息：

我在这里是写了一个简单的试例。也就是simple模式

Mq报错：Caused by: com.rabbitmq.client.ShutdownSignalException相关推荐

最新文章

热门文章