rabbitMq(一)內部訊息分發
阿新 • • 發佈:2020-09-20
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(); } }
介面