基于XMPP协议(openfire服务器)的消息推送实现
2013-11-06 20:16
411 查看
消息推送实现原理
这里的消息推送,通常是指由服务器端向客户端发送的一些消息,比如待办事宜、新闻等等。
从技术角度来看,消息推送本质上是基于TCP/IP的网络IO流传输,只不过这个IO流看起来由服务器发起,从上面的条件来看,一个基本的消息推送框架的Java实现应该是这样的:有一个用Java NIO实现的服务器,多个用socket连接到此服务器的客户端,然后之间用二进制流传输信息。说起来简单,实现起来却很不容易,所幸基于XMPP协议的openfire刚好符合上述条件,不仅如此,这种方案还有如下优点:
openfire是开源的,用Java写的,这对Java程序员来说很重要。。。
XMPP协议采用XML流传输消息,可读性和可扩展性优秀,便于我们定义自己的推送消息结构。
XMPP协议在PC和Android分别有对应的协议实现smack和asmack,不用我们写XML协议解析。
那么具体如何实现在openfire中推送消息呢?我的想法是这样的:
当两个用户使用openfire中聊天时,消息是从用户A经过服务器流向用户B,那么我们可以想象有消息中心这么一个用户,它的作用就是当我们系统有需要时,向某个用户发一条相应的消息,我们的客户端收到这样一个用户的消息时,就将其当做系统消息,这样就实现了简单的消息推送。
还有一个问题就是,系统怎么知道向哪个用户推送消息、什么时候推送消息,我们可以用http post的方式通知openfire服务器,用参数指定消息体和发送对象。
使用openfire实现消息推送
第一步,使用openfire进行消息推送的前提是在openfire系统中注册账号,有关openfire账号整合自定义数据库请看我的另一篇文章http://blog.csdn.net/nomousewch/article/details/7546083,这里就不说了。
第二步,在openfire中建立一个插件,这里贴一下核心代码:
[java]
view plaincopy
public static void pushMessage(JID to, JID from, String body,
String subject) {
Message message = new Message();
message.setFrom(from);
message.setTo(to);
message.setBody(body);
if (StringUtils.isNotBlank(subject)) {
message.setSubject(subject);
}
XMPPServer.getInstance().getRoutingTable().routePacket(to, message, true);
}
第三步,在插件中定义一个Servlet,调用上述方法。
第四步,在业务系统中用http client调用Servlet,来向指定用户推送消息。
这里的消息推送,通常是指由服务器端向客户端发送的一些消息,比如待办事宜、新闻等等。
从技术角度来看,消息推送本质上是基于TCP/IP的网络IO流传输,只不过这个IO流看起来由服务器发起,从上面的条件来看,一个基本的消息推送框架的Java实现应该是这样的:有一个用Java NIO实现的服务器,多个用socket连接到此服务器的客户端,然后之间用二进制流传输信息。说起来简单,实现起来却很不容易,所幸基于XMPP协议的openfire刚好符合上述条件,不仅如此,这种方案还有如下优点:
openfire是开源的,用Java写的,这对Java程序员来说很重要。。。
XMPP协议采用XML流传输消息,可读性和可扩展性优秀,便于我们定义自己的推送消息结构。
XMPP协议在PC和Android分别有对应的协议实现smack和asmack,不用我们写XML协议解析。
那么具体如何实现在openfire中推送消息呢?我的想法是这样的:
当两个用户使用openfire中聊天时,消息是从用户A经过服务器流向用户B,那么我们可以想象有消息中心这么一个用户,它的作用就是当我们系统有需要时,向某个用户发一条相应的消息,我们的客户端收到这样一个用户的消息时,就将其当做系统消息,这样就实现了简单的消息推送。
还有一个问题就是,系统怎么知道向哪个用户推送消息、什么时候推送消息,我们可以用http post的方式通知openfire服务器,用参数指定消息体和发送对象。
使用openfire实现消息推送
第一步,使用openfire进行消息推送的前提是在openfire系统中注册账号,有关openfire账号整合自定义数据库请看我的另一篇文章http://blog.csdn.net/nomousewch/article/details/7546083,这里就不说了。
第二步,在openfire中建立一个插件,这里贴一下核心代码:
[java]
view plaincopy
public static void pushMessage(JID to, JID from, String body,
String subject) {
Message message = new Message();
message.setFrom(from);
message.setTo(to);
message.setBody(body);
if (StringUtils.isNotBlank(subject)) {
message.setSubject(subject);
}
XMPPServer.getInstance().getRoutingTable().routePacket(to, message, true);
}
第三步,在插件中定义一个Servlet,调用上述方法。
第四步,在业务系统中用http client调用Servlet,来向指定用户推送消息。
相关文章推荐
- 基于XMPP协议(openfire服务器)的消息推送实现
- 基于XMPP协议(openfire服务器)的消息推送实现
- 基于XMPP协议(openfire服务器)的消息推送实现
- 基于XMPP协议(openfire服务器)的消息推送实现
- 基于XMPP协议(openfire服务器)的消息推送实现
- Android启动Service登陆openfire服务器实现消息推送
- 浅谈C#消息推送框架实现(Android手机openfire服务器)
- 手机服务器Android消息推送(二)--基于MQTT协议实现的推送功能
- Android 基于xmpp协议,smack包,openfire服务端的高仿QQ的即时通讯实现【5】消息发送,接收;修改心情的实现
- IOS 基于APNS消息推送原理与实现(JAVA后台)
- 服务器主动向android手机端推送消息---------Windows下实现
- PHP实现的消息实时推送功能【基于反ajax推送】
- 搭建XMPP协议,实现自主推送消息到手机
- 搭建XMPP协议,实现自主推送消息到手机
- Android消息推送(二)--基于MQTT协议实现的推送功能
- Android消息推送(二)--基于MQTT协议实现的推送功能
- Spring4.3+Webscket 实现聊天、消息推送详解原创之websocket与web服务器之间的那些纠结的事儿(二)
- Android 基于xmpp协议,smack包,openfire服务端的高仿QQ的即时通讯实现
- Fragment+定位+viewpager+基于xmpp协议的消息推送
- 搭建XMPP协议,实现自主推送消息到手机[Android版APNS]