最近重構公司消息服務的架構設計

目標

研發一套獨立的消息系統，此系統進行集中配置管理供各業務系統使用，用於支撐站內信、簡訊通知、簡訊驗證碼、郵件、微信消息、APP消息、IM等消息形式。

架構

1） 基於消息隊列採用發佈、訂閱模式。消息的生產者為對外的消息介面，接收業務系統消息後將消息寫入到消息隊列指定的topic，訂閱者對消息進行處理並行的發送消息。

2） 所有通知消息定義唯一“消息ID”來標識消息類型。

3） 通知消息由各消息模塊（簡訊、郵件、站內信、微信、APP）自己負責本消息的發送，去讀取消息節點配置信息，根據當前的消息ID判斷自己是否需要發送消息，是則發送否則丟棄。

4） 消息體，消息體採用JSON報文格式，方便各系統之間對接。

消息數據定義

{

  msghead:

{

  msgtype:””,

  msgid:””,

  rcvuid:””,

  rcvcid:””,

  rcvmobile:””,

  rcvemail:””,

  time:””,

  system:””

  }

  ,

  msgbody:

  {

text:””,

noticemsg:””,

wxmsg:””,

appmsg:””,

immsg:””,

smsmsg:[{},{}]

  }

}

項目結構

消息介面API（msg_api）

1） 負責接收業務系統發送消息請求，將消息寫到消息隊列中；

2） 提供介面供業務系統查詢，如查詢用戶的站內信消息列表、查詢驗證碼是否正確等；

3） 提供數據介面供管理平臺使用，如配置信息發送結點；

簡訊處理程式（msg_handle_sms）

1） 負責訂閱消息，讀取消息進行簡訊發送；

2） 負責驗證碼的生成處理；

3） 數據操作調用消息介面API；

4） 通知消息需要讀取配置信息決定當前消息發送或丟棄；

郵件處理程式（msg_handle_email）

1） 負責訂閱消息，讀取消息進行郵件發送；

2） 數據操作調用消息介面API；

3） 通知消息需要讀取配置信息決定當前消息發送或丟棄；

站內信處理程式(msg_handle_notice)

1） 負責訂閱消息，讀取消息進行通知；

2） 通知消息需要讀取配置信息決定當前消息發送或丟棄；

3） 數據操作調用消息介面API；

資料庫

1） 使用一個消息資料庫；

2） 資料庫表分為簡訊模塊、站內信模塊、IM模塊（暫不做）、通知信息配置模塊；