資訊專欄INFORMATION COLUMN
摘要：本來是想直接深入到的核心層去看的，但是發現其實上面的部分還有好些沒有分析到，因此回來繼續分析。另外一個，是專用于統計的，我們暫時不去關注。具體的內容我會在后面的核心層分析的時候指出。準備下一篇進行的核心層分析吧。
本來是想直接深入到mars的核心層去看的，但是發現其實上面的samples部分還有好些沒有分析到，因此回來繼續分析。
ConversationActivity這個類中實際上還做了很多的工作，在onCreate中：
final MainService mainService = new MainService();
MarsServiceProxy.setOnPushMessageListener(BaseConstants.CGIHISTORY_CMDID, mainService);
MarsServiceProxy.setOnPushMessageListener(BaseConstants.CONNSTATUS_CMDID, mainService);
MarsServiceProxy.setOnPushMessageListener(BaseConstants.FLOW_CMDID, mainService);
MarsServiceProxy.setOnPushMessageListener(BaseConstants.PUSHMSG_CMDID, mainService);
MarsServiceProxy.setOnPushMessageListener(BaseConstants.SDTRESULT_CMDID, mainService);
這里出現了一個MainService，我們來看看：
/mars-master/samples/android/marsSampleChat/app/src/main/java/com/tencent/mars/sample/core/MainService.java
public class MainService implements PushMessageHandler {
public static String TAG = "Mars.Sample.MainService";
private Thread recvThread;
private LinkedBlockingQueue pushMessages = new LinkedBlockingQueue<>();
private BusinessHandler[] handlers = new BusinessHandler[]{
new MessageHandler(),
new StatisticHandler()
};
public MainService() {
this.start();
}
public void start() {
if (recvThread == null) {
recvThread = new Thread(pushReceiver, "PUSH-RECEIVER");
recvThread.start();
}
}
private final Runnable pushReceiver = new Runnable() {
@Override
public void run() {
while (true) {
try {
PushMessage pushMessage = pushMessages.take();
if (pushMessage != null) {
for (BusinessHandler handler : handlers) {
if (handler.handleRecvMessage(pushMessage)) {
break;
}
}
}
} catch (InterruptedException e) {
e.printStackTrace();
try {
Thread.sleep(500);
} catch (InterruptedException e1) {
//
}
}
}
}
};
@Override
public void process(PushMessage message) {
pushMessages.offer(message);
}
}
1.啟動了一個接受者線程pushReceiver； 2.pushReceiver從LinkedBlockingQueue的pushMessages中不斷獲取message，然后通知到handlers的每個成員中，handlers是這樣定義的：
private BusinessHandler[] handlers = new BusinessHandler[]{
new MessageHandler(),
new StatisticHandler()
};
繼續往下看MessageHandler： /mars-master/samples/android/marsSampleChat/app/src/main/java/com/tencent/mars/sample/core/MessageHandler.java
public class MessageHandler extends BusinessHandler{
public static String TAG = MessageHandler.class.getSimpleName();
@Override
public boolean handleRecvMessage(PushMessage pushMessage) {
switch (pushMessage.cmdId) {
case Constants.PUSHCMD:
{
try {
Messagepush.MessagePush message = Messagepush.MessagePush.parseFrom(pushMessage.buffer);
Intent intent = new Intent();
intent.setAction(Constants.PUSHACTION);
intent.putExtra("msgfrom", message.from);
intent.putExtra("msgcontent", message.content);
intent.putExtra("msgtopic", message.topic);
SampleApplicaton.getContext().sendBroadcast(intent);
} catch (InvalidProtocolBufferNanoException e) {
Log.e(TAG, "%s", e.toString());
}
}
return true;
default:
break;
}
return false;
}
}
如果是Constants.PUSHCMD類型的message，那么就發送一個廣播。這個廣播實際上會由Mars核心部分接收到，但是傳遞的intent參數其實沒有意義，核心部分只是根據每次的pushcmd進行網絡狀態的檢查而已，這些后話我們在分析核心的時候再說。
另外一個StatisticHandler，是專用于統計的，我們暫時不去關注。
讓我們回到ConversationActivity，在MainService的new之后，會調用MarsServiceProxy.setOnPushMessageListener多次，設置監聽，我們來看看MarsServiceProxy里面如何運轉：
public static void setOnPushMessageListener(int cmdId, PushMessageHandler pushMessageHandler) {
if (pushMessageHandler == null) {
inst.pushMessageHandlerHashMap.remove(cmdId);
} else {
inst.pushMessageHandlerHashMap.put(cmdId, pushMessageHandler);
}
}
添加了監聽到一個支持高并發的hashmap中：
