Java連接Rabbitmq及connection error問題解決

😀 1.構建一個maven工程

---

😁 2.導入rabbitmq的maven依賴

進入網址下載，按自己的要求選擇https://mvnrepository.com/artifact/com.rabbitmq/amqp-client

進行人機驗證后搜索rabbitmq

找一個下載量多的復制代碼到 pom.xml 文件下

😡 如有報錯not found

😡 下面的依賴如果不弄連接時會報錯：“ SLF4J: Failed to load class “org.slf4j.impl.StaticLoggerBinder

解決辦法：https://www.cnblogs.com/chuchukuoai/p/14946028.html

---

😘 3.Java連接Rabbitmq

package com.rabbitmq.simple; # 前面沒弄依賴這里會報錯
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.MessageProperties;

import java.nio.charset.StandardCharsets;
import java.util.concurrent.TimeoutException;

public class Producer {
    public static void main(String[] args) {
        ConnectionFactory connectionFactory = new ConnectionFactory();
        connectionFactory.setHost(""); # 用自己的地址就好了
        connectionFactory.setPort(5672);
        connectionFactory.setUsername("admin");
        connectionFactory.setPassword("admin");
        connectionFactory.setVirtualHost("/"); # setvirtualhost可自行修改，但是要去RabbitMQ服務端修改權限，不然會報錯
        Connection connection = null;
        Channel channel = null;
        try {
            connection = connectionFactory.newConnection("生產者");
            channel = connection.createChannel();
            String queueName = "queuel";
            channel.queueDeclare(queueName, false, false, false, null);
            String message = "hello";
            channel.basicPublish("", queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
        } catch (Exception ex) {
            ex.printStackTrace();
        } finally {
            if (channel != null && channel.isOpen()) {
                try {
                    channel.close();
                } catch (Exception ex) {
                    ex.printStackTrace();
                }

                if (connection != null && connection.isOpen()) {
                    try {
                        connection.close();
                    } catch (Exception ex) {
                        ex.printStackTrace();
                    }
                }
            }

        }
    }
}

😆 4.點擊運行去RabbitMQ服務端查看結果即可