由于目前的web項(xiàng)目中要用到android手機(jī)消息推送,嘗試過(guò)很多中方式之后發(fā)現(xiàn),利用androidpn的部分代碼來(lái)實(shí)現(xiàn)這個(gè)功能是比較方便的。經(jīng)過(guò)使用tsung進(jìn)行簡(jiǎn)單的壓力測(cè)試,證明這個(gè)框架能夠滿足大多數(shù)簡(jiǎn)單應(yīng)用的需求。
Androidpn包含有server和client兩個(gè)包,server部分可以作為服務(wù)器單獨(dú)運(yùn)行,也可以嵌入到web項(xiàng)目的servlet中,在tomcat環(huán)境中與web項(xiàng)目的其他部分交互。androidpn的簡(jiǎn)單用法網(wǎng)上已經(jīng)有很多文章介紹,這里就不細(xì)說(shuō)了。主要談?wù)勅绾螌ndroidpn和自己的web程序整合到一起。
Server部分的主要包結(jié)構(gòu)如下:
其中org.androidpn.server.dao,org.androidpn.server.model和org.androidpn.server.service為使用hibernate鏈接數(shù)據(jù)庫(kù)并實(shí)現(xiàn)簡(jiǎn)單的用戶登錄認(rèn)證,開(kāi)發(fā)中可以用我們自己的認(rèn)證模塊替換。剩下的包就是推送的主體實(shí)現(xiàn)。
接下來(lái)逐個(gè)包來(lái)看:
1.util包中的類(lèi)用來(lái)加載resources中的配置文件,在配置文件中可指定監(jiān)聽(tīng)端口和ssl證書(shū)目錄等屬性。
2.org.androidpn.server.xmpp包里面定義了一些異常類(lèi)型,主要是包含有入口類(lèi)XmppServer,這個(gè)類(lèi)用來(lái)啟動(dòng)和停止server程序。
3.org.androidpn.server.xmpp.auth包里面是認(rèn)證的一些類(lèi),我們自己的認(rèn)證模塊可以在這里與androidpn進(jìn)行結(jié)合。
4.org.androidpn.server.xmpp.codec是XMPP協(xié)議的XML文件解析包,server收到和發(fā)送的消息都要通過(guò)這個(gè)包來(lái)進(jìn)行xmpp協(xié)議編碼和解碼。
5.org.androidpn.server.xmpp.handler包主要是對(duì)消息的處理,我們可以針對(duì)不同的消息類(lèi)型定義自己的handler,
6.org.androidpn.server.xmpp.net包負(fù)責(zé)維護(hù)與client之間的持久連接,并實(shí)現(xiàn)了一些傳輸方式供發(fā)送xmpp消息時(shí)使用。
7.org.androidpn.server.xmpp.presence里面只包含PresenceManager類(lèi),用來(lái)維護(hù)client的在線狀態(tài)。
8.org.androidpn.server.xmpp.push包里面的NotificationManager類(lèi)包含有向client發(fā)送消息的接口。
9.org.androidpn.server.xmpp.router包負(fù)責(zé)將收到的信息包發(fā)送到相應(yīng)的handler進(jìn)行處理,是一個(gè)路由包。
10.org.androidpn.server.xmpp.session包定義了用來(lái)表示持久鏈接的session,每個(gè)session包含一條連接的狀態(tài)信息。
11.org.androidpn.server.xmpp.ssl是對(duì)連接進(jìn)行ssl認(rèn)證的工具包。
server發(fā)送消息的整個(gè)流程主要是:
1. NotificationManager的push接口被調(diào)用。
2.使用SessionManager在當(dāng)前session集合中查找相應(yīng)的client鏈接。
3.定義自己的XMPP消息格式并組裝。
4.通過(guò)相應(yīng)session,向client發(fā)送消息。
在這個(gè)流程中我們需要修改的是步驟3,也就是需要定義和組裝自己的xmpp消息,以便于將適當(dāng)?shù)男畔鞯娇蛻舳瞬⒈阌诳蛻舳私馕觥R粋€(gè)簡(jiǎn)單的消息組裝例子如下:
- private IQcreateMessageIQ(Stringtitle,Stringmessage,StringuserId,
- Stringjson){
- Elementnotification=DocumentHelper.createElement(QName.get(
- "message" ,INQURIE_NAMESPACE));
- notification.addElement( "title" ).setText(title);
- notification.addElement( "text" ).setText(message);
- notification.addElement( "userId" ).setText(userId);
- notification.addElement( "json" ).setText(json);
- IQiq= new IQ();
- iq.setType(IQ.Type.set);
- iq.setChildElement(notification);
- return iq;
- }
server端接收和處理消息的流程是:
1.connection收到packet,使用tsc.push.server.xmpp.codec解碼。
2.router根據(jù)packet的namespace等信息,將packet路由到相應(yīng)的handler。
3.handler進(jìn)行處理。
相應(yīng)的router和handler類(lèi)在androidpn中都有例子可以參考,這里就不貼代碼了。開(kāi)發(fā)中只要根據(jù)client發(fā)送消息的格式,定義自己的router和handler類(lèi),然后在PacketRouter中注冊(cè)router,在IQRouter中注冊(cè)handler即可。
Client部分的主要包結(jié)構(gòu)如下:
Client 這邊包含有消息的收發(fā),解析以及持久連接的發(fā)起,重連等功能呢,十分強(qiáng)大,我們開(kāi)發(fā)時(shí)完全不用管底層的連接,也不用擔(dān)心斷線,可以專(zhuān)注于業(yè)務(wù)部分的開(kāi)發(fā)。
同時(shí),代碼結(jié)構(gòu)也很簡(jiǎn)單。去除android的Service和BroadCast類(lèi)以及一些工具類(lèi)和常量類(lèi)不談:
1.NotificationIQ,NotificationIQProvider,NotificationPacketListener三個(gè)類(lèi)負(fù)責(zé)對(duì)收到的Notification格式的消息進(jìn)行解析和處理,
2.XmppManager是主控制器,NotificationService通過(guò)這個(gè)類(lèi),在后臺(tái)維護(hù)androidpn連接。
3.PersistentConnectionListener,PhoneStateChangeListener,ReconnectionThread.java三個(gè)類(lèi)則負(fù)責(zé)監(jiān)聽(tīng)手機(jī)的狀態(tài)并進(jìn)行斷線重連。
我們自定義消息時(shí)需要定義3個(gè)類(lèi):在***IQ中定義消息的實(shí)體,在***IQProvider中將消息轉(zhuǎn)化為***IQ實(shí)體,在***PacketListener中對(duì)實(shí)體進(jìn)行處理,具體的實(shí)現(xiàn)可參考NotificationIQ,NotificationIQProvider,NotificationPacketListener三個(gè)類(lèi)。在定義這些類(lèi)之后,還需要在XmppManager中將這3個(gè)類(lèi)中注冊(cè)到connection中,代碼如下:
- //ConnectTask
- <spanstyle= "white-space:pre" ></span>connection.connect();
- Log.i(LOGTAG, "XMPPconnectedsuccessfully" );
- //packetprovider
- ProviderManager.getInstance().addIQProvider( "message" ,
- Constants.NOTIFICATION_NAMESPACE,
- new NotificationIQProvider());
- //LoginTask
- <spanstyle= "white-space:pre" ></span> //packetfilter
- PacketFilterpacketFilter= new PacketTypeFilter(
- NotificationIQ. class );
- //packetlistener
- PacketListenerpacketListener=xmppManager
- .getNotificationPacketListener();
- connection.addPacketListener(packetListener,packetFilter);
以上就是我在開(kāi)發(fā)過(guò)程中的一些體會(huì),有不對(duì)的地方希望大家指正~

更多文章、技術(shù)交流、商務(wù)合作、聯(lián)系博主
微信掃碼或搜索:z360901061

微信掃一掃加我為好友
QQ號(hào)聯(lián)系: 360901061
您的支持是博主寫(xiě)作最大的動(dòng)力,如果您喜歡我的文章,感覺(jué)我的文章對(duì)您有幫助,請(qǐng)用微信掃描下面二維碼支持博主2元、5元、10元、20元等您想捐的金額吧,狠狠點(diǎn)擊下面給點(diǎn)支持吧,站長(zhǎng)非常感激您!手機(jī)微信長(zhǎng)按不能支付解決辦法:請(qǐng)將微信支付二維碼保存到相冊(cè),切換到微信,然后點(diǎn)擊微信右上角掃一掃功能,選擇支付二維碼完成支付。
【本文對(duì)您有幫助就好】元
