增加maven配置文件

<dependency><groupId>com.rabbitmq</groupId><artifactId>amqp-client</artifactId><version>3.6.5</version></dependency> 復制代碼

生產者
package com.jeff.boot.controller.rabbitmq; 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 Producer { public final static String QUEUE_NAME="rabbitMQtest";

public static void main(String[] args) throws IOException, TimeoutException {//創建連接工廠ConnectionFactory factory = new ConnectionFactory();//設置RabbitMQ相關信息factory.setHost("");factory.setUsername("");factory.setPassword("");factory.setPort(5672);//創建一個新的連接Connection connection = factory.newConnection();//創建一個通道Channel channel = connection.createChannel();// 聲明一個隊列channel.queueDeclare(QUEUE_NAME, false, false, false, null);String message = "Hello RabbitMQ";int i = 0;//發送消息到隊列中while (i < 100 ) {channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));System.out.println("Producer Send +'" + message + "'");//關閉通道和連接i++;}channel.close();connection.close(); } 復制代碼

}

消費者
package com.jeff.boot.controller.rabbitmq;

import com.rabbitmq.client.*; import java.io.IOException; import java.util.concurrent.TimeoutException;

public class Customer { private final static String QUEUE_NAME = "rabbitMQtest";

public static void main(String[] args) throws IOException, TimeoutException {// 創建連接工廠ConnectionFactory factory = new ConnectionFactory();//設置RabbitMQ地址factory.setHost("192.168.226.53");//創建一個新的連接Connection connection = factory.newConnection();//創建一個通道Channel channel = connection.createChannel();//聲明要關注的隊列channel.queueDeclare(QUEUE_NAME, false, false, false, null);System.out.println("Customer Waiting Received messages");//DefaultConsumer類實現了Consumer接口，通過傳入一個頻道，// 告訴服務器我們需要那個頻道的消息，如果頻道中有消息，就會執行回調函數handleDeliveryConsumer consumer = new DefaultConsumer(channel) {@Overridepublic void handleDelivery(String consumerTag, Envelope envelope,AMQP.BasicProperties properties, byte[] body)throws IOException {String message = new String(body, "UTF-8");System.out.println("Customer Received '" + message + "'");}};//自動回復隊列應答 -- RabbitMQ中的消息確認機制channel.basicConsume(QUEUE_NAME, true, consumer); } 復制代碼

}

創作挑戰賽新人創作獎勵來咯，堅持創作打卡瓜分現金大獎

總結

以上是生活随笔為你收集整理的rabbitmq java 应用实例的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。