[转]Android 基于Netty的消息推送方案(一)

时间：2024-03-12 20:38:23

前言：最近在头痛一个server 推送方案，要准实时，支持多客户端同时在线。推送只是p2p; 陆续会整理一些质料记录在此，这是第一篇。

消息推送方案（轮询、长连接）

轮询

轮询：比较简单的，最容易理解和实现的就是客户端去服务器上拉信息，信息的及时性要求越高则拉信息的频率越高。客户端拉信息的触发可以是一些事件，也可以是一个定时器，不断地去查询服务器。所以这个方案的弊端也是显而易见的，在轮询的频率较高时，服务器端的压力很大，通讯的流量也很大，并且大部分时间都是做的无用功。

长连接

长连接：客户端和服务端维持一个长连接，服务端在有信息推送的时候，借助这个连接把信息发送到客户端。这个方案的优点是信息推送的及时性很高，基本是实时的，并且除了维持连接的心跳，不会产生额外的流量，但服务端需要维持连接，当客户端数量庞大的时候，服务器的资源消耗也会很大。本文后面提到的几个框架，都借助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下载

官网下载或者CSDN下载

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的使用。

相关文章