【已解决】 com.rabbitmq.client.ShutdownSignalException: connection error； protocol meth

测试代码：

public class Producer {
    public static void main(String[] args) throws IOException, TimeoutException {
        // ConnectionFactory是RabbitMQ数据库的物理连接
        ConnectionFactory connectionFactory = new ConnectionFactory();
        // 服务器的本地ip地址
        connectionFactory.setHost("127.0.0.1");
        //服务器端口号，5672是MQ的默认端口号
        connectionFactory.setPort(5672);
        //设置用户名和密码
        connectionFactory.setUsername("guest");
        connectionFactory.setPassword("guest");
        // 连接的是哪一个虚拟主机
        connectionFactory.setVirtualHost("/test");
        // 获取一个物理TCP的物理连接
        Connection connection = connectionFactory.newConnection();
 
        // 创建通信通道，相当于TCP中的虚拟连接,在通道中进行数据传输
        Channel channel = connection.createChannel();
 
        //通道创建好了，现在创建一个队列,如果队列存在则使用这个队列
        // 第一个参数：队列名称ID
        // 第二个参数：队列是否持久化，false是不进行持久化
        // 第三个参数：队列是否被私有化，false是所有的消费者都可以访问，true是只有第一次拥有的消费者可以访问使用
        // 第四个参数：是否自动删除，false代表的是不自动删除这个队列
        // 其他参数
        channel.queueDeclare("helloworld",false,false,false,null);
 
        // 在通道里面设置发送的内容
 
        //第一个参数是交换机
        //第二个参数是队列的队列名
        //第三个个参数是额外属性
        // 第四个参数是要传递消息的字节数组
        String message = "helloworld!";
 
        channel.basicPublish("", "helloworld", null, message.getBytes());
        // 关闭通道
        channel.close();
        // 关闭连接
        connection.close();
        System.out.println("发送成功！");
    }
}

测试消息中间件RabbitMQ连接的时候出现异常。

意思是用户访问RabbitMQ虚拟机的时候出现异常，这里可能是权限不够。

代码段：

rabbitmqctl set_permissions -p "/" username ".*" ".*" ".*"

在安装路径sbin 下

测试成功！