1. 程式人生 > >rabbitmq方法及引數個人見解

rabbitmq方法及引數個人見解

引數詳解
1.channel.basicPublish(String exchange, String routingKey, boolean mandatory, BasicProperties props, byte[] body)
方法:釋出訊息
exchange:將訊息釋出到哪
routingKey:路由鍵
mandatory:true為強制
props:訊息路由標題等的其他屬性
body:訊息內容


2.channel.queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete, Map<String, Object> arguments)
方法:建立一個佇列
queue:佇列名稱
durable:是否宣告一個持久化佇列,伺服器重啟時還存在
excluesive:設定一個排他設定,僅限用於此連線
autoDelete:是否自動刪除,伺服器不使用他時,自動刪除
argument:佇列其他引數設定


3.channel.basicConsume(String queue, boolean autoAck, String consumerTag, boolean noLocal, boolean exclusive, Map<String, Object> arguments, final Consumer callback)
方法:啟動一個消費者。
queue:佇列名
autoAck:true表示伺服器等訊息一次性交付過來,false表示伺服器期望等到訊息
consumerTag:客戶端生成的使用者標籤來建立上下文
noLocal:如果伺服器不應傳遞到此通道連線上釋出的消費者訊息
exclusive:這是否是一個專有的消費
argumnets:佇列其他引數設定
callback:與消費者對接的介面






4.connection.creatChannel(int channelNumber)
方法:建立一個渠道,
channelNumber:分配的渠道號