Android 基于Netty的消息推送方案之Hello World(一)
消息推送方案(轮询、长连接)
轮询
轮询:比较简单的,最容易理解和实现的就是客户端去服务器上拉信息,信息的及时性要求越高则拉信息的频率越高。客户端拉信息的触发可以是一些事件,也可以是一个定时器,不断地去查询服务器。所以这个方案的弊端也是显而易见的,在轮询的频率较高时,服务器端的压力很大,通讯的流量也很大,并且大部分时间都是做的无用功。
长连接
长连接:客户端和服务端维持一个长连接,服务端在有信息推送的时候,借助这个连接把信息发送到客户端。这个方案的优点是信息推送的及时性很高,基本是实时的,并且除了维持连接的心跳,不会产生额外的流量,但服务端需要维持连接,当客户端数量庞大的时候,服务器的资源消耗也会很大。本文后面提到的几个框架,都借助Java的NIO特性,缓解了服务端的压力和资源消耗,但毕竟是有连接,在性能上还是无法跟传统的HTTP无连接服务端比较。
其他
其他:在手机端,其实还可以有短信、邮件等方式,来进行信息推送。这些方式由于牵涉到运营商和手机操作系统的内置服务框架,限制较多,何况微信都要被收费,所以就不去考虑了。
开源框架(Androidpn Openfire MINA Netty)
Android手机应用,信息推送的资料大多都是关于androidpn的,这是一个基于XMPP协议的Java开源信息推送方案,包括完整的服务端和客户端。服务端有Tomcat和Jetty两个版本,下载下来后配置一下数据库连接参数和IP端口就可以跑起来了。客户端则可以参考它的示例,把Android代码拿过来用即可。所以这是一个针对android应用的高度定制版,如果要对服务端进行修改调整,动的地方比较多。
Openfire则适用的范围更广,是基于XMPP协议的开源实时协作服务器,可以通过它简单地搭建一个IM平台。Androidpn是在Openfire上做了简化,只针对Android的消息推送。从这里也可看出,就消息推送来说,用XMPP协议有点杀鸡用牛刀了。
MINA和Netty是Socket框架,是同一个作者的,架构差别不大。MINA归Apache管,Openfire和Androidpn都是用的MINA;Netty则归JBOSS管,从我检索到的资料来看,更多偏向于Netty,大致是认为Netty的性能稍优,文档与例子更完整。
消息推送服务(GCM C2DM 百度云推送)
其实也有一些现存的云推送服务可供选择,并不一定要自己来搭建一个平台。谷歌的GCM,Google Cloud Messaging,是C2DM的升级版,Android终端用的话,本来是最合适不过了,但在国内大家都懂的,玩的是《墙来了》游戏,有时你可以钻过去,有时会被撞落水,所以不靠谱啊。百度和其他的一些公司,也提供云推送服务,好像没有免费的。谷歌应该比较郁闷吧,Android上的搜索、地图、邮件、推送等等,在国内都是为他人作嫁衣裳。
回归本质-协议(TCP/IP HTTP XMPP MQTT)
没想到一个消息推送可以有这么多“内涵”啊。本质上,不就是维持一个连接,服务端需要推送消息的时候就通过这些连接往客户端传信息嘛。仔细想来,要想灵活和可控,最好的方式还是自己基于TCP/IP协议来实现消息推送。再往上一点,就是在HTTP协议上来实现,这样的话既可以穿越防火墙,也可以通过AJAX实现网页上的消息推送。Servlet 3.0的异步请求支持,其实也是可以用来做消息推送的。XMPP和MQTT协议要复杂些,最好选一个开源框架来搭建。
Netty简介
Netty是一个异步的,事件驱动的网络编程框架和工具,是一个基于NIO的客户,服务器端编程框架,使用Netty可以确保你快速和简单的开发出一个网络应用,例如实现了某种协议的客户,服务端应用。Netty相当简化和流线化了网络应用的编程开发过程,例如,TCP和UDP的socket服务开发。
Netty下载
Netty入门(Hello World)
在Eclipse中新建java工程,将netty.jar包放入lib目录下,然后build path -->add to build path,目录结构如下
客户端代码如下
- public class HelloClient {
- public static void main(String args[]) {
- // Client服务启动器
- ClientBootstrap bootstrap = new ClientBootstrap(new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
- // 设置一个处理服务端消息和各种消息事件的类(Handler)
- bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
- @Override
- public ChannelPipeline getPipeline() throws Exception {
- return Channels.pipeline(new HelloClientHandler());
- }
- });
- // 连接到本地的8000端口的服务端
- bootstrap.connect(new InetSocketAddress("127.0.0.1", 8000));
- }
- private static class HelloClientHandler extends SimpleChannelHandler {
- @Override
- public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
- System.out.println("Hello world, I‘m client.");
- }
- }
- }
服务端代码如下
- public class HelloServer {
- public static void main(String[] args) {
- // Server服务启动器
- ServerBootstrap bootstrap = new ServerBootstrap(new NioServerSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
- // 设置一个处理客户端消息和各种消息事件的类(Handler)
- bootstrap.setPipelineFactory(new ChannelPipelineFactory() {
- @Override
- public ChannelPipeline getPipeline() throws Exception {
- return Channels.pipeline(new HelloServerHandler());
- }
- });
- // 开放8000端口供客户端访问。
- bootstrap.bind(new InetSocketAddress(8000));
- }
- private static class HelloServerHandler extends SimpleChannelHandler {
- @Override
- public void channelConnected(ChannelHandlerContext ctx, ChannelStateEvent e) {
- System.out.println("Hello world, I‘m server.");
- }
- }
- }
首先运行服务端,然后运行客户端,效果如下
下面我会进一步讲解Netty的使用。
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。