消息中心構(gòu)架設(shè)計說明書

1、消息中心構(gòu)架設(shè)計說明書版本：1.0變更記錄序號版本變更說明修改人/日期審批人/日期11.0創(chuàng)建李力鴻目錄1 1.文檔介紹41.1 文檔目的41.2 文檔范圍41.3 讀者對象41.4 參考文獻(xiàn)41.5 術(shù)語與縮寫解釋42 系統(tǒng)概述53 設(shè)計約束64 設(shè)計策略75 系統(tǒng)總體結(jié)構(gòu)86 子系統(tǒng)N的結(jié)構(gòu)與功能157 開發(fā)環(huán)境的配置278 運行環(huán)境的配置289 測試環(huán)境的配置2910 其它301 1.文檔介紹1.1 文檔目的消息中心接收別的系統(tǒng)發(fā)送的消息，再基于一定的規(guī)則以郵件、短信、消息等方式推送消息到pc端和手機端，比如對于attendance遲到、早退、tour超時提醒等需要及時推送相應(yīng)的信息給相

2、關(guān)人員，中心對規(guī)則、用戶、消息進(jìn)行管理。為此，根據(jù)“先進(jìn)實用、穩(wěn)定可靠”的原則設(shè)計本消息中心。1.2 文檔范圍消息的接收、發(fā)送、保存，對應(yīng)用用戶的管理。1.3 讀者對象開發(fā)人員1.4 參考文獻(xiàn)1.5 術(shù)語與縮寫解釋縮寫、術(shù)語解釋QoSlevelQualityofServicelevelSD系統(tǒng)設(shè)計，SystemDesign2系統(tǒng)概述系統(tǒng)主要完成消息的接收、發(fā)送和保存，再基于一定的規(guī)則以郵件、短信、消息等方式推送消息到pc端或手機，以及對用戶、規(guī)則、消息進(jìn)行管理。系統(tǒng)接收來自別的系統(tǒng)應(yīng)用用戶的消息，然后基于一定的規(guī)則把消息進(jìn)行推送。3設(shè)計約束1 .系統(tǒng)必須遵循國家軟件開發(fā)的標(biāo)準(zhǔn)。2 .系統(tǒng)用ja

3、va開發(fā)，服務(wù)器中間件為tomcat。3 .系統(tǒng)必須穩(wěn)定可靠，性能高，滿足每天40-500萬次的推送量。4 .保證消息的成功送達(dá)，如果不成功就重發(fā)。4設(shè)計策略1 .系統(tǒng)高可用、高性能、易擴展，安全穩(wěn)定，實用可靠，滿足用戶的需要。2 .系統(tǒng)可以進(jìn)行擴展，增加推送的消息種類，增加消息推送的規(guī)則。3 .系統(tǒng)可以復(fù)用于別的系統(tǒng)的消息推送。5系統(tǒng)總體結(jié)構(gòu)5.1系統(tǒng)架構(gòu)設(shè)計1.邏輯架構(gòu)系統(tǒng)采用接口用rocketMQ實現(xiàn)應(yīng)用用戶的消息接收，用drools依據(jù)一定的規(guī)則進(jìn)行消息轉(zhuǎn)發(fā)，發(fā)送郵件、短信、消息到pc端和手機端，消息發(fā)送后用rocketMQ發(fā)送結(jié)果消息給應(yīng)用用戶。用戶管理發(fā)送規(guī)則，對不同的消息、發(fā)送的

4、方式、發(fā)送的時間、接收者進(jìn)行設(shè)置，以后消息中心按照這些規(guī)則發(fā)送消息。規(guī)則處理采用drools完成。系統(tǒng)采用MQT用艮務(wù)器mosquito實現(xiàn)消息對手機端的推送，采用winsocket發(fā)送消息給pc端。MQTffi過發(fā)布/訂閱方式發(fā)送消息給手機，方式為發(fā)布/訂閱,為了實現(xiàn)點對點發(fā)送，需要在發(fā)送的消息里加上手機端的imei和用戶名，同時在手機端進(jìn)行判斷，如果imei和用戶名符合則接收此消息。采用winsocket實現(xiàn)推送消息到pc端，為實現(xiàn)點對點的推送，可以在消息中加上要發(fā)送的pc端的用戶名，pc端對消息的用戶名進(jìn)行判斷，如果和自己的一樣則接收消息。對于群發(fā)，大家都可以收到。應(yīng)用用戶通過接口發(fā)送消

5、息給消息中心，消息采用json格式，包含應(yīng)用用戶id、發(fā)送消息方式id、Title、content、usrld,sendTime。采用mqttQoSlevel2協(xié)議，保證自動重發(fā)發(fā)送不成功的消息，而且可以保證消息的順序到達(dá)，可以設(shè)置超時時間，防止斷網(wǎng)。Mqtt不建立長連接，省電、省流量。還可以用mosquitto實現(xiàn)集群發(fā)送，集群可以線性擴展。應(yīng)用系統(tǒng)用戶在注冊、登陸后申請發(fā)送消息的類別，有郵件、短信、手機消息、pc消息4種，注冊后要記住自己的id,然后通過接口發(fā)送消息；管理員審批用戶的申請，管理消息；消息中心發(fā)送消息或郵件、短信到相應(yīng)的pc端或手機端用戶。系統(tǒng)的管理功能包括對規(guī)則、用戶、消息

6、進(jìn)行管理。中心的時區(qū)設(shè)當(dāng)?shù)氐臅r區(qū)，系統(tǒng)用ntpdate命令讓系統(tǒng)使用NTP（NetworkTimeProtocol網(wǎng)絡(luò)時間協(xié)議）協(xié)議來從網(wǎng)絡(luò)同步時間的命令，這樣即使有夏令時的變化，系統(tǒng)也會自動更新。中心使用時間時需要得到系統(tǒng)的時區(qū)。2.網(wǎng)絡(luò)架構(gòu)5.2 系統(tǒng)包含模塊1 .消息接收發(fā)送模塊。1）提供發(fā)送接口用于接收應(yīng)用用戶的消息和參數(shù)，然后通過規(guī)則發(fā)送消息，用戶通過接收接口得到發(fā)送結(jié)果：發(fā)送消息到手機端。發(fā)送消息到pc端。發(fā)送郵件。發(fā)送短信。2 .手機、pc接收模塊。手機接收消息中心發(fā)送的消息。Pc接收消息中心發(fā)送的消息。3 .管理模塊。1）用戶和管理員注冊、登陸。2）實現(xiàn)用戶申請消息發(fā)送方式申請

7、、查看消息、修改密碼、統(tǒng)計消息。用戶可以申請郵件、短信、手機消息、pc消息4種方式發(fā)送消息。3）管理用戶、審批用戶發(fā)送方式、管理員密碼修改、查看和統(tǒng)計發(fā)送過的消息。4）管理規(guī)則，可以增加、修改、刪除查詢規(guī)則。5.3 用例圖2.管理員用例圖3消息用戶用例圖4.應(yīng)用用戶用例圖5.4流程圖1.發(fā)送消息流程圖6系統(tǒng)模塊的結(jié)構(gòu)與功能系統(tǒng)包括消息接收送接模塊、手機、pc接收消息模塊、管理模塊，共3個模塊。6.1 消息接收發(fā)送模塊提供接口用于接收應(yīng)用用戶的消息，然后用drools通過規(guī)則異步發(fā)送消息，用戶調(diào)用接收接口得到發(fā)送結(jié)果：發(fā)送消息到手機端。發(fā)送消息到pc端。發(fā)送郵件。發(fā)送短信。系統(tǒng)采用rocketm

8、q接收消息和返回消息發(fā)送結(jié)果給用戶，系統(tǒng)給pc、手機采用Async異步發(fā)送郵件等消息，并得到發(fā)送結(jié)果，把結(jié)果返回給調(diào)用者，消息及發(fā)送的情況入庫，入庫時需要檢查消息是否已經(jīng)存在。用戶采用異步調(diào)用本接口，得到發(fā)送結(jié)果，如果不成功，用戶可以重發(fā)。因為中心的時區(qū)與各用戶的時區(qū)不同，用戶需要發(fā)送自己的時區(qū)，系統(tǒng)返回發(fā)送時間時要根據(jù)時區(qū)轉(zhuǎn)換時間。當(dāng)手機離線沒有收到消息，則在定時器中重發(fā)；對于需要定時發(fā)送的消息，通過定時器完成發(fā)送。定時器20分鐘執(zhí)行一次，對這2種情況通過規(guī)則發(fā)送消息。系統(tǒng)確定時間時要根據(jù)時區(qū)進(jìn)行轉(zhuǎn)換，按照用戶的時區(qū)時間來發(fā)送消息。6.1.1 單元定義單元名稱單元功能描述備注com.isof

9、tstone.message.domain.Message消息實體com.isoftstone.message.MessageBiz消息發(fā)送接收業(yè)務(wù)類com.isoftstone.message.dao.MessageDao消息管理dao類com.isoftstone.message.service.MessageService消息管理service類com.isoftstone.message.mailMessage發(fā)送郵件com.isoftstone.message.shortMessage發(fā)送短信com.isoftstone.message.pcMessage發(fā)送pc消息com.isof

10、tstone.message.MobileMessage發(fā)送手機消息6.1.2接口描述1.發(fā)送接口接口定義：publicvoidsendMessage(StringapplicationId,Stringtypeid,Stringtitle,Stringcontent,StringuserId)throwsException；描述：通過調(diào)用此接口可發(fā)送消息及參數(shù)，接口在com.isoftstone.message.MessageBiz中。入口參數(shù)父TOftTOft須必類型備注applicationId-StringM丫typeidOStringtitleString,contentOStrin

11、guserIdStringsendTimeStringtimeZoneString2.接收接口接口定義：publicIntegergetMessageResult(StringapplicationId,Stringtypeid,Stringtitle,Stringcontent,StringuserId)throwsException；描述：通過調(diào)用此接口可得到發(fā)送消息的結(jié)果，如果發(fā)送失敗，用戶則調(diào)用發(fā)送接口重發(fā)。接口在com.isoftstone.message.MessageBiz中。入口參數(shù)父TOftTOft須必類型備注applicationldMStringtypeidOString

12、titleString,userIdStringsendTimeStringtimeZoneString接口返回:返回碼含義備注0成功1失敗2數(shù)據(jù)重復(fù)提交3服務(wù)器異常4沒有發(fā)送權(quán)限5網(wǎng)絡(luò)異常時序圖何一一色”匚工£KMba.電,二區(qū)小j'j'Vnri.I：'MU，：；II'!基本場景以下場景觸發(fā)模塊：用戶調(diào)用接口發(fā)送消息。時序圖及描述流程描述：1 .用戶使用接口發(fā)送消息及參數(shù)。2 .接口對消息參數(shù)進(jìn)行分析，判斷是否可以發(fā)送。3 .接口根據(jù)參數(shù)分別異步發(fā)送郵件、短信、手機、pc消息，并得到發(fā)送結(jié)果，反饋給接口調(diào)用者。4 .發(fā)送消息后保存消息到數(shù)據(jù)庫。異常描

13、述IO異常：數(shù)據(jù)插入失敗，寫入日志。數(shù)據(jù)庫操作異常：數(shù)據(jù)插入失敗，寫入日志網(wǎng)絡(luò)連接超時異常：網(wǎng)絡(luò)異常，發(fā)送失敗，寫入日志并反饋給用戶。6.2 手機、pc接收模塊6.2.1 手機接收消息中心發(fā)送的消息手機用mqtt接收消息。6.2.2 Pc接收消息中心發(fā)送的消息。Pc用winsocket接收消息。6.3 管理模塊。6.3.1 用戶和管理員注冊、登陸。用戶和管理員注冊、登陸。應(yīng)用用戶注冊后記住自己的id,以后發(fā)送消息時會用到。6.3.2 用戶操作功能。實現(xiàn)用戶申請消息發(fā)送方式申請、查看消息、修改密碼、統(tǒng)計消息。用戶可以申請郵件、短信、手機消息、pc消息4種方式發(fā)送消息。6.3.3 管理功能。管理規(guī)

14、則、用戶、審批用戶發(fā)送方式、管理員密碼修改、查看和統(tǒng)計發(fā)送過的消息。規(guī)則以xml格式生成。6.3.4 注冊、登陸界面完成應(yīng)用用戶和注冊、登陸。仲管理員0應(yīng)用用戶注照用戶至二電話：enail:備注:F密科：蠟證密科二注冊放奔6.3.5 用戶申請界面實現(xiàn)用戶申請消息發(fā)送方式申請。用戶可以申請郵件、短信、手機消息、pc消息4種方式發(fā)送消息。1 .應(yīng)用用戶消息管理'應(yīng)用用戶消息管理由消息管理丫密碼管理應(yīng)用用戶消息管理n郵件B矩信手機消息npc消息保存放棄2 .應(yīng)用用戶消息管理應(yīng)用用戶酒顯管理消息管理潼碼塔理1消息管理應(yīng)用用戶名掰：口:用戶1序言消息id消息類型消息標(biāo)題消息內(nèi)容接收入發(fā)送日期S1

15、11122手機消息超時清盡快完成行秀5145U5152015-4-5是2111123部件加班通知周末加班6SS20134-5是第1頁洪1頁，3 .應(yīng)用用戶密碼管理應(yīng)用用戶消息置理肖息管叫密碼管理Ir密封宣理4.發(fā)送管理舊畬碼:新密碼:蛉證新密碼;£所展3ID«Cttt叵q6gQ，輻帆盾理口那目即D應(yīng)用陰修理口聊潮口卿府口拼k胴戶苕良醴.施W1|任匹百追I發(fā)生意迎"郵昕馥"的颯用戶褊癱當(dāng)皂二且-：|pEJtl7爰僵力擠530朝母法*三時五氐開精園日向于而c擅股府戶翻t口施用戶k本籍強員匚本E和二沫申討運際布而5.應(yīng)用用戶消息統(tǒng)計悒用用戶消身管理清思管理密碼

16、宜建I麗消息管理應(yīng)用用戶自掰：XX用戶1序號消息id消息類型消息標(biāo)題消息內(nèi)答接收入發(fā)送日期是否成功111122手機消息超時請盡快棄成任轉(zhuǎn)5145U51520154-5是2111123部件加更通知周末加班656126com20134-6是第1頁洪1頁電6.3.6管理界面管理員實現(xiàn)對應(yīng)用用戶的管理、對應(yīng)用用戶申請的管理和對消息的管理，及管理員注冊、登陸。1 .應(yīng)用用戶管理應(yīng)用兄戶苣理聞用力消息管理消息管理1r空碼管理應(yīng)用用戶篦理期芝加刷新序罟應(yīng)用用戶名標(biāo)日朝上傳人甫比處理1XX用育201345孚日均總不回息刪除2XX用戶220134-5郭清1同身不1可息刪除，第1頁.共1頁,/超2 .應(yīng)用用戶消息

17、審批管理應(yīng)而用戶*理同用用戶消息管理ISsm1r引得/理一薪一應(yīng)用用戶消息省理應(yīng)用用戶茗稱二由語日期:IB司|臼查暨重蠱嚼而庫一國色鮑|J幅新序號應(yīng)問用廣電稱日期上傳人消息方式畝假1Xx用力1如245李白部年同意不同意2用戶1如必-薛怡,同總不同意3湍用引20134s孚日手機消息。同苴不同意HkHtJ.rfuI號-bi2.消息管理1r應(yīng)用用戶宜迎他用用戶消息管城僮愿管理1r密碼管理j消息首展利新序4應(yīng)用用戶名赭消息泣消息類型消恿標(biāo)題消息內(nèi)容接收入也送口期處理1XX用戶111122手機出息端育尺快餐成住男514514515?0154-6tlrtFf2XK用戶1111123越佳加班也知閔洋埴打GE

18、6125com取1345刪除IW4第1負(fù)共1負(fù)*i34.管理員密碼管理密碼管理統(tǒng)計,應(yīng)用用戶管理但用用戶消息管理消息管理壟碼管理舊登碼：I-新密碼;一放盲I叁證領(lǐng)率內(nèi)：一5.消息統(tǒng)計'施用隹廣管理”應(yīng)用用戶消息置理伯息管理|窗鶴曾理|麗,虢外應(yīng)用用戶名稱X左送日期;圜早Ig亙詢I里置制將序號應(yīng)用同尸名稱應(yīng)用用戶id手機消息印箱息郵件短信發(fā)送日期戰(zhàn)功思翕成S不功效成功率1XX用戶11122221(2>22<3)33(4)333(E)20164522399%2.«1頁甚1頁，,W5.規(guī)則管理WtWifip-F井1*K回/*WQ節(jié)日渺於£三周好PI里Huim印

19、nwi潮ri：rffJOiffa育條查的£36.規(guī)則編輯iS：U內(nèi)有劇學(xué)期£ftff;明埔自|匕世力典+加且|x“Q1*自禮宣典飄魂曲D矩冏戶醯匚顆醺口刎手口比7開發(fā)環(huán)境的配置類別標(biāo)準(zhǔn)配置最低配置計算機硬件Pcwindos軟件eclipse網(wǎng)絡(luò)通信Tcp/ip其它8運行環(huán)境的配置類別標(biāo)準(zhǔn)配置最低配置計算機硬件服務(wù)器軟件Linux網(wǎng)絡(luò)通信Tcp/ip其它9測試環(huán)境的配置同開發(fā)環(huán)境10其它10.1數(shù)據(jù)庫設(shè)計t_message_subscribe_typeidbigint<pk>namevarchar(50reamarkvarchar(100)deletedtinyi

20、ntt_application_useridbigint<pk>namevarchar(50)emailvarchar(128)telephonevarchar(32)remarkvarchar(100)passWordvarchar(50)registerTimedatetimedeletedtinyintt_adminidbigint<pk>namevarchar(50)emailvarchar(128)telephonevarchar(32)remarkvarchar(100)passWordvarchar(50)registerTimedatetimedelet

21、edtinyintt_ruleidbigint<pk>namevarchar(100)contentvarchar(1000)createTimedatetimeupdateTimedatetimeremarkdatetimedeletedintidbigint<pk>titlevarchar(80)contentvarchar(500)sendTimedatetimestatustinyintremarkvarchar(100)receiveUserIdvarchar(50)applicationTypeIdbigintdeletedtinyintt_mobile_m

22、essaget_application_message_typet_email_messageidbigint<pk>applicationIdbiginttypeIdbigintnamevarchar(50)remarkvarchar(100)agreeintdeletedintapplyTimedatetimeidbigint<pk>titlevarchar(80)contentvarchar(500)sendTimedatetimedsttinyintstatustinyintremarkvarchar(100)receiveUserIdvarchar(50)ap

23、plicationTypeIdbigint.不t_userc_timeZoneidbigint<pk>countryvarchar(80)timeZonevarchar(100)keyvarchar(100)createTimedatetimeupdateTimedatetimeremarkdatetimedeletedtinyintidbigint<pk>countryvarchar(80)timeZonevarchar(100)keyvarchar(100)createTimedatetimeupdateTimedatetimeremarkdatetimedelet

24、edtinyintt_timeZonet_short_messageidbigint<pk>titlevarchar(80)contentvarchar(500)sendTimedatetimestatustinyintremarkvarchar(100)receiveUserIdvarchar(50)applicationTypeIdbigintdeletedtinyintt_pc.messageJdbigint<pk>titlevarchar(80)contentvarchar(500)sendTimedatetimestatustinyintremarkvarch

25、ar(100)receiveUserIdvarchar(50)applicationTypeIdbigintdeletedtinyint10.1.1 郵件消息表t_email_message主要用途：保存發(fā)送的郵件數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由用戶調(diào)用操作FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintpkM標(biāo)題titlevarchar(80)M內(nèi)容contentvarchar(500)M發(fā)送時間sendTimedatetimeM接收時間ReceiveTimedatetime發(fā)送狀態(tài)sta

26、tustinyintM接收用戶idreceiveUserIdvarchar(50)應(yīng)用用戶idapplicationTypeIdbigint是否刪除deletedtinyint10.1.2 手機消息表t_mobile_message主要用途：保存發(fā)送的手機消息數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由用戶調(diào)用操作FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintpkM標(biāo)題titlevarchar(80)M內(nèi)容contentvarchar(500)M發(fā)送時間sendTimedatetimeM接收時間Rec

27、eiveTimedatetime發(fā)送狀態(tài)statustinyintM接收用戶idreceiveUserIdvarchar(50)應(yīng)用用戶idapplicationTypeIdbigint是否刪除deletedtinyint10.1.3 短信消息表t_short_message主要用途：保存發(fā)送的短信消息。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由用戶調(diào)用操作FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintpkM標(biāo)題titlevarchar(80)M內(nèi)容contentvarchar(500)M發(fā)送時間s

28、endTimedatetimeM發(fā)送狀態(tài)statustinyintM接收時間ReceiveTimedatetime接收用戶idreceiveUserIdvarchar(50)應(yīng)用用戶idapplicationTypeIdbigint是否刪除deletedtinyint10.1.4 管理員表t_admin主要用途：保存管理員信息。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由用戶注冊、修改決定。FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintpkM姓名namevarchar(30)Memailemailva

29、rchar(128)M電話telephonevarchar(M32)密碼passWordvarchar(50)M注冊時間registerTimedatetime是否刪除deletedtinyint10.1.5 發(fā)送消息用戶表t_application_user主要用途：保存發(fā)送消息用戶信息。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由用戶注冊、修改決定。FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintpkM姓名namevarchar(30)Memailemailvarchar(128)M電話teleph

30、onevarchar(32)M密碼passWordvarchar(50)M注冊時間registerTimedatetime是否刪除deletedtinyint10.1.6 消息訂閱類別表t_message_subscribe_type主要用途：保存用戶消息訂閱方式信息。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由管理員操作決定。FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintPkM方式namevarchar(30)M郵件備注reamarkvarchar(128)M是否刪除deletedtinyint10

31、.1.7 國家時區(qū)表t_timeZone主要用途：提供各個國家時區(qū)，為管理員指定中心的時區(qū)服務(wù)。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由管理員修改決定FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULTVALUEDESCRIPTIONididbigintPkM國家countryvarchar(80)M時區(qū)timeZonevarchar(100)MkeykeydatetimeM用于國際化id產(chǎn)生時間createTimedatetime備注remarkbigint是否刪除deletedtinyint10.1.8 使用時區(qū)表t_userd_timeZone主要用途：保存消息中心的時區(qū)，時區(qū)可以由系統(tǒng)自動獲取，也可以由管理員指定。數(shù)據(jù)增長頻率：個數(shù)據(jù)保存周期：由管理員修改決定FIELDNAMEFIELDCODEFIELDYPEFIELDLENGTHKEYO/MDEFAULT