傳送訊息(所謂的生產者)
rabbitmq:
host: 127.0.0.1
listener:
acknowledge-mode: manual
password: 自己的密碼
port: 5672
username: 自己的使用者名稱
virtual-host: /develop(虛擬伺服器,相當於許可權設定)
mq配置類
@configuration
public class rabbitconfig implements rabbitlistenerconfigurer ")
private string host;
@value("$")
private integer port;
@value("$")
private string username;
@value("$")
private string password;
@value("$")
private string virtualhost;
@bean
public connectionfactory connectionfactory()
@bean
public ******rabbitlistenercontaine***ctory rabbitlistenercontaine***ctory()
@bean
public rabbittemplate rabbittemplate(connectionfactory connectionfactory)
@override
public void configurerabbitlisteners(rabbitlistenerendpointregistrar registrar)
@bean
public rabbitadmin rabbitadmin(connectionfactory connectionfactory)
}
傳送訊息:
注入 rabbittemplate rabbittemplate;
rabbittemplate.convertandsend("交換機名稱", "繫結佇列的routingkey",自己需要發的資訊);
備註:訊息最好使用,string,json,map等如果傳入物件,那麼物件必須在相同的目錄下,名字並且相同
消費端:
配置交換機,配置佇列
@enablerabbit
@component
public class myrabbitmqconfig
/*** 佇列
*/@bean(name = "creditqueue")
public queue creditqueue()
/***繫結佇列
*/ @bean
public binding creditqueuebinding(@qualifier("creditqueue") queue creditqueue, @qualifier("exchangedirect") exchange exchangedirect)
}
訊息消費:建立***
@component
public class rabbitmqclientlistener catch (exception e)
}}
RabbitMQ使用詳解
rabbitmq 企業級訊息佇列,遵循 amqp 協議,基於 erlang 語言開發,在可靠性 易用性和高可用等方面都比較優秀的乙個訊息中介軟體。在網際網路專案中,常見用途 服務之間的業務解耦,避免發布時互相影響 非同步資料處理,以快速返回應答,包括日誌的收集和業務的處理 流量控制,避免瞬間突發資料...
RabbitMQ 詳解以及使用場景
mq全稱為message queue,訊息佇列 mq 是一種應用程式對應用程式的通訊方法。應用程式通過讀寫出入佇列的訊息 針對應用程式的資料 來通訊,而無需專用連線來鏈結它們。訊息傳遞指的是程式之間通過在訊息中傳送資料進行通訊,而不是通過直接呼叫彼此來通訊,直接呼叫通常是用於諸如遠端過程呼叫的技術。...
rabbitmq 配置詳解
一般情況下,rabbitmq的預設配置就足夠了。如果希望特殊設定的話,有兩個途徑 乙個是環境變數的配置檔案 rabbitmq env.conf 乙個是配置資訊的配置檔案 rabbitmq.config 注意,這兩個檔案預設是沒有的,如果需要必須自己建立。rabbitmq env.conf 這個檔案的...