異步手機短信和郵件發(fā)送消息中心平臺構(gòu)建

異步手機短信和郵件發(fā)送消息中心平臺構(gòu)建【文章摘要】針對RPC中間件技術(shù)而對規(guī)模和復(fù)雜度相對較高的分布式系統(tǒng)時,在同步通信、客戶和服務(wù)對象的生命周期緊密耦合、點對點通信上所顯示出的局限性，提出了一種異步手機短信和郵件發(fā)送消息中心平臺（MCP）解決方案。發(fā)送者將消息發(fā)送給消息服務(wù)器，消息服務(wù)器將消息存放在若干隊列中，在合適的時候再將消息轉(zhuǎn)發(fā)給接收者?！娟P(guān)鍵詞】MCP；SMS；ActiveMQ0引言隨著網(wǎng)絡(luò)的發(fā)展，系統(tǒng)的分布更加的復(fù)雜，系統(tǒng)和系統(tǒng)之前的異步通信是一個急需解決的問題；現(xiàn)在幾乎每一個人都有一部電話，每天都接觸電腦接觸網(wǎng)絡(luò)，為了拋棄以前的紙上、當(dāng)面的辦公模式,系統(tǒng)和人手中的電話、系統(tǒng)和每個人的各種通信工具的異步通信成為問題的關(guān)鍵。為滿足在分布式環(huán)境下企業(yè)應(yīng)用對性能、安全性、穩(wěn)定性等方而的要求，可以構(gòu)建基于消息的中間件的數(shù)據(jù)通信系統(tǒng)。它能夠異步傳遞消息將彼此獨立的計算機連接起來組成松耦合的系統(tǒng)，并且可以有效地屏蔽細節(jié)對外提供統(tǒng)一的服務(wù)。這樣不但可以節(jié)約交通工具的成木，還可以提高辦公的效率。1異步手機短信和郵件發(fā)送消息中心平臺構(gòu)建消息中心平臺是用于軟件系統(tǒng)內(nèi)部和外部消息傳遞的中間件服務(wù),提供消息的發(fā)送，接收，重復(fù)消息的壓縮，重要消息的升級，短信消息(SMS)，郵件消息(Email)，離線消息，消息群發(fā)，消息轉(zhuǎn)發(fā),平臺獨立運行。1.1消息平臺需求分析收發(fā)短信：通過短信網(wǎng)關(guān)和短信貓完成短消息的收發(fā)和消息格式的轉(zhuǎn)換，便于同第三方系統(tǒng)的交互。收發(fā)郵件：通過收發(fā)郵件的功能，提供客戶以郵件的方式與第三方系統(tǒng)進行交互。JMS消息交互：第三方系統(tǒng)通過消息中心API來實現(xiàn)短信和郵件的發(fā)送和接收。消息驗證：對于客戶端發(fā)來的信息，首先進行驗證,如果符合條件則進行發(fā)送。不符合條件持久化后丟棄。確保消息的完整性，屏蔽垃圾信息。自動從連：由于客戶端、服務(wù)器或者網(wǎng)絡(luò)原因造成客戶端到服務(wù)器的連接中斷，待可正常連接時，客戶端可自動從新連接到服務(wù)器，增強程序的健壯性。自動從發(fā)：當(dāng)短信或者郵件消息發(fā)送失敗后,時隔一定時長后可自動從新發(fā)送，確保在可控制范圍內(nèi)的消息不丟失行。清空消息隊列：對于發(fā)送隊列中的消息，由于客戶的需要可對其清空不發(fā)送。日志處理：用戶可以查詢消息發(fā)送和接收日志，手動清除消息日志；程序可自動定期備份消息FI志。程序監(jiān)控：用戶可以監(jiān)控部署MCP的服務(wù)器的CPU、內(nèi)存的占用情況,保證消息服務(wù)器健康運行；監(jiān)控消息的收發(fā)成功和失敗的數(shù)量,得到MCP消息的丟失率。1.2消息平臺總體設(shè)計木系統(tǒng)為純后臺程序，第三方系統(tǒng)通過客戶端連接到服務(wù)器端進行發(fā)送消息。采用支持JMS1.1規(guī)范的ActiveMQ進行消息的接收和發(fā)送。ActiveMQ設(shè)置兩個通道，一個用來接收消息的接收通道,一個用來發(fā)送消息的發(fā)送通道。第三方系統(tǒng)通過集成客戶端發(fā)送消息到ActiveMQoMCP自身有一個消費者，此消費者監(jiān)聽接收通道，監(jiān)聽到消息,先判斷類型然后通過IPX/短信網(wǎng)關(guān)接口、郵件接口把消息發(fā)送出去，當(dāng)IPX/短信網(wǎng)關(guān)接口或者郵件接口接收到消息則通過一個消息創(chuàng)建者把消息發(fā)送到消息發(fā)送通道上，集成客戶端的第三方系統(tǒng)監(jiān)聽消息發(fā)送通道就可以接收到MCP的消息了。1.3系統(tǒng)功能模塊劃分消息管理：負責(zé)消息的發(fā)送，接收，壓縮,升級,轉(zhuǎn)換，持久化，日志記錄。性能監(jiān)控：負責(zé)消息中心的監(jiān)控，包括：CPU、內(nèi)存利用率,消息隊列的狀態(tài)，還可以控制連接的啟動和停止，消息的測試，消息通道的建立和刪除功能。日志管理：記錄消息日志，錯誤消息日志，并且能核查消息錯誤原因。客戶端管理：負責(zé)連接消息中心，注冊客戶端，注銷客戶端，斷開連接,發(fā)送消息，接收消息，心跳監(jiān)聽。1.4消息平臺接口設(shè)計1.4.1用戶接口（1） 集成系統(tǒng)：導(dǎo)入消息中心平臺的JAR包,實現(xiàn)提供給客戶端的接口。（2） 維護人員：通過JDK自帶的監(jiān)控功能，即可進行消息中心的監(jiān)控和維護。（3） 客戶端：是第三方系統(tǒng)與消息中心服務(wù)器溝通的橋梁，只有把消息中心客戶端集成到第三方系統(tǒng)中，第三方系統(tǒng)才可以與消息中心服務(wù)器發(fā)送和接收消息。1.4.2外部接口短信網(wǎng)關(guān)接口：IPX短信網(wǎng)關(guān)使用的是WebSerivce接口。短信Modem接口：金笛短信Modem串行接口。郵件接口：Gmail的郵件接口，發(fā)送郵件協(xié)議為SMTP,接收郵件的協(xié)議為IMAP協(xié)議。1.5消息平臺運行設(shè)計1.5.1運行模塊組合系統(tǒng)的每個模塊都依賴于消息中心模塊，每個模塊獨立的,沒有依賴關(guān)系。1.5.2運行控制（1）首先啟動消息中心平臺,建立消息通道，監(jiān)聽連接，監(jiān)聽消息;連接短信網(wǎng)關(guān)和短信Model,監(jiān)聽短信；連接郵件服務(wù)器，監(jiān)聽郵件；（2） 第三方系統(tǒng)連接消息中心平臺，監(jiān)聽信息。（3） 短信貓、短信網(wǎng)關(guān)和郵件如果連接失敗，通過定時器定時重連。1.5.3運行時間一般用戶的操作響應(yīng)時間應(yīng)在2秒鐘左右，測試、文檔備份、數(shù)據(jù)的導(dǎo)入和導(dǎo)出操作的時間會相對較長一些，但是操作也在可接受的時間內(nèi)完成。1.6消息平臺數(shù)據(jù)庫設(shè)計對于發(fā)送到消息中心平臺的所有消息都需要進行入庫操作。用于H后的日志查詢。基木信息表記錄消息的共同屬性，其中包括消息的主題、消息的目的地址（消息的接收人）、消息的發(fā)送人、消息的類型、消息的優(yōu)先級、消息的發(fā)送時間、消息的接收時間、消息是否發(fā)送成功、消息發(fā)送的次數(shù)等。通過這些信息，可以統(tǒng)計岀消息發(fā)送成功和失敗的數(shù)量，同時也可以查看出每條消息的詳細信息。消息其他信息的存儲：由于消息包括郵件、短信消息。因此，對于短信和郵件分別有一張表，存儲自己特有的字段。客戶端注冊信息的存儲：客戶端有管理功能,對于客戶端的一些信息需要進行入庫操作。啟動一個ActiveMQ服務(wù)器以后會有一個broker,通過創(chuàng)建ConnectFactory進行對消息進行處理。為了起到安全作用，在服務(wù)器端設(shè)置連接ConnectFactory的賬號和密碼。因此,當(dāng)客戶端在創(chuàng)建ConnectFactory時候，就會通過帳號密碼進行驗證,如果通過則可以與服務(wù)器端進行連接，反之不可。此外，對客戶端的一些其他信息進行了保存，以便對客戶端的統(tǒng)計和查詢功能的實現(xiàn)。消息平臺服務(wù)器的基木配置：對于消息平臺服務(wù)器端的一些配置進行了數(shù)據(jù)庫的存儲。主要是針對消息平臺處理的消息的長度、消息隊列的長度、發(fā)送消息的閥值、消息升級的策略、消息壓縮的策略的值的存儲。2結(jié)論消息平臺的構(gòu)建實現(xiàn)了：（1）收發(fā)短信：通過短信網(wǎng)關(guān)和短信貓完成短消息的收發(fā)和消息格式的轉(zhuǎn)換,便于同第三方系統(tǒng)的交互。（2）收發(fā)郵件，通過收發(fā)郵件的功能,提供客戶以郵件的方式與第三方系統(tǒng)進行交互。（3）JMS消息交互,第三方系統(tǒng)通過我們API來實現(xiàn)短信和郵件的發(fā)送和其他附加功能的實現(xiàn)。（4）消息中