pom檔案

    <dependencies>
        <dependency>
            <groupId>com.rabbitmq</groupId>
            <artifactId>amqp-client</artifactId>
            <version>5.1.2</version>
        </dependency>
    </dependencies>

測試

public static void main(String[] args) {
        //建立連線工廠
        ConnectionFactory factory = new ConnectionFactory();

        // 設定連線屬性
        factory.setHost("localhost");
        factory.setPort(5672);
        factory.setUsername("admin");
        factory.setPassword("admin");

        Connection connection = null;
        Channel channel = null;

        try{
            // 3、 從連結工廠獲取連線
            connection = factory.newConnection("生產者");

            // 4、從連結中建立通道
            channel = connection.createChannel();

            /**
             * 5、宣告佇列
             * @param queue 佇列名稱
             * @param durable 是否持久化
             * @param exclusive 是否排他
             * @param autoDelete 是否自動刪除
             * @param arguments 佇列引數
             */
            //channel.queueDeclare("qeueu1", false, false, null)
            channel.queueDeclare("queue1", false, false,false, null);

            //訊息內容
            String message = "hellow world";

            // 6、發起訊息
            channel.basicPublish("","queue1",null,message.getBytes());
            System.out.println("訊息已傳送。");


        }catch (IOException e){
            e.printStackTrace();
        }catch (TimeoutException e1){
            e1.printStackTrace();
        }
    }

介面