rabbitMq 使用詳解

2021-10-17 04:01:50 字數 1786 閱讀 1977

傳送訊息(所謂的生產者)

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 這個檔案的...