MQ與Spring的整合

2021-07-22 05:22:24 字數 1418 閱讀 1415

activemq與spring的整合

首先將activemq如下的jar包匯入專案中。

配置activemq的spring配置檔案

<?xml version="1.0" encoding="utf-8"?>

然後依次實現訊息的轉換器activemqmessageconverter

public class activemqmessageconverter implements messageconverter 

/*** 轉換接收訊息。

*/@override

public object frommessage(message msg) throws jm***ception

}

訊息的生產者messageproducer

public class messageproducer

}

訊息的消費者messageconsumer(可擴充套件)
/**

* 從訊息佇列中讀取物件,並且進行訊息傳送。

* * @author zxh

* */

public class messageconsumer

/*** 傳送訊息

* * @param model

* 傳送的物件

* @throws exception

*/public void sendmessage(object model) throws exception

else

} else }}

activemq應用場景

訊息佇列是分布式系統中重要的元件,可以解決非同步處理,應用接耦,流量削峰,日誌處理,訊息通訊

非同步處理:使用者註冊後需要傳送註冊郵件和註冊簡訊,就可以放入訊息佇列中,不用管了,它會處理直到處理成功

應用解耦:使用者下單並支付成功後,就會有如下流程:1,成本核算2,庫存系統減少3,財務通知,4商家通知等等是在同一事務中,如果這4步任何一部出現錯誤或拋異常,這樣事務就會回滾,錢又退回使用者賬號,這是絕對不能出現的情況,我們可以把這4個流程放在乙個訊息佇列中,相互互不影響,只要放入訊息佇列,就不用管了,以下4個流程會訂閱取得訊息

流量削峰:一般出現在秒殺或者團搶活動中,放到訊息佇列中,1.可以控制活動的人數(如果訊息佇列長度超過最大數量就會直接拋棄或者跳轉到錯誤頁面),2,可以緩解短時間高流量壓垮應用(起到緩衝的作用,然後再處理秒殺業務)。

日誌處理:日誌採集客戶端把日誌寫入kafka訊息佇列,然後日誌處理應用去訂閱

訊息通訊:聊天室功能

Struts與Spring的整合

struts核心是mvc,struts與spring的整合就是把struts的action交給spring去管理,從而達到簡化程式的目的 一 配置spring上下文和監聽 配置spring上下文和監聽有兩種方式 方式一 web.xml web主要配置檔案 而主要用於監聽web的上下文,可用下面 代替...

ibatis與spring的整合

sqlmapconfig.xml配置非常簡單 usermap.xml配置如下 select from user select u.id,u.name,s.score from user u right join score s on u.id s.uid select from user where...

spring與jbpm的整合

spring與jbpm的整合 由spring容器產生processengine jbpm的事務交給spring處理 整合步驟 匯入jbpm的jar包 刪除db和hibernate的jar包 在config下建立乙個配置檔案 config jbpm jbpm.cfg.xml jbpm.hibernat...