虽然google为Android开发者提供了GCM实现push，但是因为需要系统安装了google play、google帐号、系统>2.2、google push服务器在国外等多种原因，在中国，Android上想实现push还需要自己努力。
当前最火的开源push是基于xmpp协议的androidpn。androidpn是基于Mina框架的，所以这里从Mina框架开始入手。
Server
下面通过简单的例子来学习mina的使用。首先创建服务端，工程正使用了3个jar包
看代码：
- public class HelloMina {
- private static final int PORT = 9125;
- /**
- * @param args
- * @throws IOException
- */
- public static void main(String[] args) throws IOException {
- //创建一个非阻塞的server端Socket ，用NIO
- IoAcceptor acceptor = new NioSocketAcceptor();
- acceptor.getFilterChain().addLast( "logger", new LoggingFilter() );
- acceptor.getFilterChain().addLast( "codec", new ProtocolCodecFilter( new TextLineCodecFactory( Charset.forName( "UTF-8" ))));
- // 设定服务器端的消息处理器
- acceptor.setHandler( new MinaServerHandler() );
- acceptor.getSessionConfig().setReadBufferSize( 2048 );
- acceptor.getSessionConfig().setIdleTime( IdleStatus.BOTH_IDLE, 10 );
- // 服务器端绑定的端口 启动服务
- acceptor.bind( new InetSocketAddress(PORT) );
- }
- }
HelloMina的处理器：
- /**
- * HelloMina的处理逻辑
- * @author zhangxy
- */
- class MinaServerHandler extends IoHandlerAdapter {
- @Override
- public void exceptionCaught( IoSession session, Throwable cause ) throws Exception{
- cause.printStackTrace();
- session.close();
- }
- @Override
- public void messageReceived( IoSession session, Object message ) throws Exception
- {
- String str = message.toString();
- if( str.trim().equalsIgnoreCase("quit") ) {
- session.close();
- return;
- }
- System.err.println("收到客户端发来的消息：："+str);
- StringBuilder buf = new StringBuilder(str.length());
- for (int i = str.length() - 1; i >= 0; i--) {
- buf.append(str.charAt(i));
- }
- // and write it back.
- session.write(buf.toString());
- }
- @Override
- public void sessionIdle( IoSession session, IdleStatus status ) throws Exception{
- System.out.println( "IDLE " + session.getIdleCount( status ));
- }
- @Override
- public void messageSent(IoSession session, Object message)
- throws Exception {
- // TODO Auto-generated method stub
- super.messageSent(session, message);
- }
- @Override
- public void sessionClosed(IoSession session) throws Exception {
- // TODO Auto-generated method stub
- super.sessionClosed(session);
- System.out.println( "session closed");
- }
- @Override
- public void sessionCreated(IoSession session) throws Exception {
- // TODO Auto-generated method stub
- super.sessionCreated(session);
- System.out.println( "session create");
- }
- @Override
- public void sessionOpened(IoSession session) throws Exception {
- // TODO Auto-generated method stub
- super.sessionOpened(session);
- System.out.println( "session opened");
- }
- }
client
下面是Client代码，Client没有使用NIO，使用的普通socket实现：
- public class HelloMinaClient {
- private Socket socket;
- private DataOutputStream out;
- private DataInputStream in;
- public HelloMinaClient() throws IOException {
- }
- /**
- * @param args
- */
- public static void main(String[] args) throws Exception {
- // TODO Auto-generated method stub
- HelloMinaClient minaClient = new HelloMinaClient();
- minaClient.minaClient();
- }
- /**
- * 发送消息
- * @param out
- */
- public void sendMessage(Socket s) {
- try {
- out = new DataOutputStream(s.getOutputStream());
- out.writeBytes("mina\n");
- } catch (IOException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- }
- }
- public void receiveMessage(Socket s) {
- try {
- in = new DataInputStream(s.getInputStream());
- System.err.println("收到服务端发来的消息：："+in.readLine());
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- public void minaClient() throws Exception {
- while (true) {
- try {
- socket = new Socket("192.168.21.121", 9124);
- sendMessage(socket);
- receiveMessage(socket);
- out.close();
- in.close();
- Thread.sleep(5000);
- } catch (InterruptedException e) {
- // TODO Auto-generated catch block
- e.printStackTrace();
- } catch(Exception e){
- e.printStackTrace();
- }finally {
- try{
- if(socket!=null)socket.close(); //断开连接
- }catch (IOException e) {e.printStackTrace();}
- }
- }
- }
- }
SOCKET作为短连接，即收发消息后SOCKET断开一次，线程过5秒又建立连接收发消息。
/**
* @author 张兴业
* 邮箱：xy-zhang#163.com
* android开发进阶群：278401545
* http://blog.csdn.net/xyz_lmn
* http://xyzlmn.blog.51cto.com/
*/
本文转自xyz_lmn51CTO博客，原文链接：http://blog.51cto.com/xyzlmn/1089948，如需转载请自行联系原作者
