(一)androidpn-server tomcat版源码解析之--项目启动

最新项目在搞安卓推送，选用的xmpp协议，用了一套androidpn推送框架服务端是tomcat的版本的androidpn-server，网上对于这套服务端源码的理解比较少，于是我抽空把源码给解析了一遍并且了解到了整个服务的启动过程。

下面是项目的git地址:https://github.com/msdx/androidpn/tree/master/androidpn-server-bin-tomcat

工程本身是一套tomcat的web工程，有控制台，本文将从工程建立的视角来观察源码

•  入口web.xml

和大多数web工程一样，本项目的入口也是web.xml，通过web.xml启动spring，下面是源码

web.xml

 

<context-param>									
		<param-name>contextConfigLocation</param-name>							
		<param-value>							
			/WEB-INF/applicationContext*.xml						
        </param-value>									
</context-param>									

 实际上WEB-INF下并没有applicationContext*.xml(估计是没有配置正确)，而是使用了dispatcher-servlet.xml

 

 

 

 

dispatcher-servlet.xml

 

<bean id="notificationController"			
	class="org.androidpn.server.console.controller.NotificationController">		
	<property name="methodNameResolver" ref="paramResolver" />		
</bean>			

 在dispatcher-servlet.xml中配置了一个Controller，spring初始化时候会去调用NotificationController的构造方法来生成一个实例

 

 

 

NotificationApiController的构造方法

 

    public NotificationApiController() {				
        notificationManager = new NotificationManager();				
    }				

 

 

 

NotificationManager的构造方法

 

    /**			
     * Constructor.			
     */			
public NotificationManager() {			
   sessionManager = SessionManager.getInstance();			
   notificationService = ServiceLocator.getNotificationService();			
   userService = ServiceLocator.getUserService();			
}			

 ServiceLocator.getNotificationService()和ServiceLocator.getUserService()其实就是从spirng的bean工程中获取service方法不用太在意，下一步到SessionManager.getInstance()

 

 

 

SessionManager

 

private SessionManager() {				
   serverName = XmppServer.getInstance().getServerName();//####启动了XmppServer，成为了重要线索			
}				
	
			
    /**				
     * Returns the singleton instance of SessionManager.				
     * 				
     * @return the instance				
     */				
public static SessionManager getInstance() {				
     if (instance == null) {				
        synchronized (SessionManager.class) {				
           instance = new SessionManager();				
          }				
      }				
      return instance;				
    }				

 

 

 

• Mina  server

他的名字虽然是XmppServer，但其实只是load了另外一个spirng的xml,从整体的角度来说，XmppServer的作用是开启一个mina的监听server端，下面先来补充一下mina的知识

一句话概括:mina为开发高性能和高可用性的网络应用程序提供了非常便利的框架。也就是说它是一套网络通信框架，基于socket的。

他的demo如下

 public class HelloServer {

	private static final int PORT = 8080;

	/**
	 * @param args
	 * @throws IOException
	 */
	public static void main(String[] args) throws IOException {
		IoAcceptor acceptor = new SocketAcceptor();
		IoAcceptorConfig config = new SocketAcceptorConfig();
		DefaultIoFilterChainBuilder chain = config.getFilterChain();
		// 使用字符串编码
		chain.addLast("codec", new ProtocolCodecFilter(new TextLineCodecFactory()));
		// 启动HelloServer
		acceptor.bind(new InetSocketAddress(PORT), new HelloHandler(), config);
		System.out.println("HelloServer started on port " + PORT);
	}
}

/**
 * HelloServer的处理逻辑
 * 
 * @author liudong
 */
class HelloHandler extends IoHandlerAdapter {
	/**
	 * 当有异常发生时触发
	 */
	@Override
	public void exceptionCaught(IoSession ssn, Throwable cause) {
		cause.printStackTrace();
		ssn.close();
	}

	/**
	 * 有新连接时触发
	 */
	@Override
	public void sessionOpened(IoSession ssn) throws Exception {
		System.out.println("session open for " + ssn.getRemoteAddress());
	}

	/**
	 * 连接被关闭时触发
	 */
	@Override
	public void sessionClosed(IoSession ssn) throws Exception {
		System.out.println("session closed from " + ssn.getRemoteAddress());
	}

	/**
	 * 收到来自客户端的消息
	 */
	public void messageReceived(IoSession ssn, Object msg) throws Exception {
		String ip = ssn.getRemoteAddress().toString();
		System.out.println("===> Message From " + ip + " : " + msg);
		ssn.write("Hello " + msg);
	}
}											

 再引用一张架构图:

 

 整体表达的意思也就是，client的请求最后都会交给handler类去执行，用户自己的handler只要去继承IoHandlerAdapter这个父类，就可以拥有 sessionOpened,sessionClosed,messageReceived的功能，客户端的请求也最终分发到了handler类的对应方法

 

 

好了补充完了mina的知识再回到主题，刚才说到XmppServer去load了另外一个spirng.xml，下面是XmppServer.java的源码

 

/**	
     * Returns the singleton instance of XmppServer.	
     *	
     * @return the server instance.	
     */	
    public static XmppServer getInstance() {	
        // return instance;	
        if (instance == null) {	
            synchronized (XmppServer.class) {	
                instance = new XmppServer();	
            }	
        }	
        return instance;	
    }	
	
    /**	
     * Constructor. Creates a server and starts it.	
     */	
    public XmppServer() {	
        if (instance != null) {	
            throw new IllegalStateException("A server is already running");	
        }	
        instance = this;	
        start();	
    }	
	
    /**	
     * Starts the server using Spring configuration.	
     */	
    public void start() {	
        try {	
            if (isStandAlone()) {	
                Runtime.getRuntime().addShutdownHook(new ShutdownHookThread());	
            }	
	
          //  locateServer();	
            serverName = Config.getString("xmpp.domain", "127.0.0.1")	
                    .toLowerCase();	
            context = new ClassPathXmlApplicationContext("spring-config.xml");	 //#######################没错这个xml的名字在这里
            log.info("Spring Configuration loaded.");	
	
//            AdminConsole adminConsole = new AdminConsole(serverHomeDir);	
//            adminConsole.startup();	
//            if (adminConsole.isHttpStarted()) {	
//                log.info("Admin console listening at http://"	
//                        + adminConsole.getAdminHost() + ":"	
//                        + adminConsole.getAdminPort());	
//            }	
            log.info("XmppServer started: " + serverName);	
            log.info("Androidpn Server v" + version);	
	
        } catch (Exception e) {	
            e.printStackTrace();	
            shutdownServer();	
        }	
    }	

 

 

 原来是spring-config.xml，下面则是spring-config.xml的关键内容

 

<bean id="xmppHandler" class="org.androidpn.server.xmpp.net.XmppIoHandler" />			
<bean id="ioAcceptor" class="org.apache.mina.transport.socket.nio.NioSocketAcceptor"			
	init-method="bind" destroy-method="unbind">		
		<property name="defaultLocalAddress" value=":5222" />	
		<property name="handler" ref="xmppHandler" />	
		<property name="filterChainBuilder" ref="filterChainBuilder" />	
		<property name="reuseAddress" value="true" />	
	</bean>		

 

 原来，工程在spirng类中又配了一个bean，这个bean是org.apache.mina.transport.socket.nio.NioSocketAcceptor，并且ioc注入了监听的端口号，以及对应的handler类，打开工程中的org.androidpn.server.xmpp.net.XmppIoHandler类，我们就明白了，所有client的链接最初都被发到这个类中，然后再进行了相应的处理。

 

 

以上基本阐述了整个项目的基本流程，下篇文章，我将继续分析XmppIoHandler往下的流程，来看androidpn是如何实现实时推送和链接状态维护的

 

 

 

 

 

 

 

原创文章，转载请声名出处http://spjich.iteye.com/admin/blogs/2225830

 

 

 

 

评论

1 楼 龙宇2013 2015-07-10  

博主这篇文章很及时啊，最近我也在研究，有时间聊聊吗