訊息佇列MQ的使用流程

2021-08-28 06:39:50 字數 1190 閱讀 1613

人工智慧,零基礎入門!

在大型平台的分布式專案中,訊息佇列mq具有重要的作用,經常用在邊緣業務功能的處理中,比如日誌管理【下面將以bug日誌儲存為例】,因為像日誌儲存、新使用者註冊傳送郵件等操作都不是主幹業務,可以放在訊息佇列非同步處理,這樣可以減小專案的阻塞和壓力。下面介紹的是比較常用的乙個訊息佇列activemq。

就以bug日誌儲存為例,介紹一般的業務邏輯:【如下圖**示例】

寫乙個介面,

然後呼叫注入的service的業務邏輯方法,

介面返回結果,流程結束。

首先要有另外乙個新的mq專案伺服器,用於接收訊息,和處理訊息,暴露介面出來即可,

在原先的專案業務上修改:請求mq專案暴露出來的介面,把資料傳過去,如果是傳輸的資料是物件得注意這個物件進行序列話【就是實現serializable介面】

需要注意的是,原先的專案中的service的業務邏輯**要copy到mq專案中,到這裡你可能就明白了mq的實現原理:原先的專案就負責傳送訊息給mq專案,然後mq專案上有一套完全一樣的業務處理**,mq專案在拿到訊息後再慢慢處理訊息【非同步進行】,說通俗一點,就相當於將業務轉移到另外乙個專案。

原先專案中的service方法要copy過來,還有對應的實體類也要copy一致,

寫乙個接收訊息的介面:

生產訊息的生產端【生產者】

消費訊息的消費端 【消費者】

配置queue的名字

這是簡單的運用,用起來還是蠻簡單的,但是要了解裡面的原理還要多多學習原始碼。

訊息佇列MQ

目錄 一 簡介 二 為什麼需要訊息佇列 mq 三 介紹 訊息佇列 message queuing 在電腦科學中,是一種程序間通訊或同一程序間不同執行緒的通訊方式。廣義上講訊息佇列是解決分布式系統中,各個功能模組間的資訊傳遞通訊方式。與檔案傳輸和rpc相比,訊息佇列具有更好的平台無關性,並能夠很好地支...

MQ訊息佇列

1.解耦 系統a將userid寫到訊息佇列中,系統c和系統d從訊息佇列中拿資料。這樣有什麼好處?系統a只負責把資料寫到佇列中,誰想要或不想要這個資料 訊息 系統a一點都不關心。即便現在系統d不想要userid這個資料了,系統b又突然想要userid這個資料了,都跟系統a無關,系統a一點 都不用改。系...

Windows訊息佇列MQ的使用

在系統間的進行資料傳遞,特別是資料量較大,分別插入不同的資料庫的時候。同時保證系統效率和響應時間,減少資料庫負擔的時候,使用訊息佇列是非常有幫助的。廢話不多說,直接上 把下面的 建為基類直接呼叫就可以了 using system.messaging 標頭檔案 using system using s...