OpenFire源码学习之十二：HttpBind&Script Syntax

标签：httpbind   script syntax   openfire   socket   im通讯   

HttpSessionManager

该类管理所有通过httpbing连接到openfire的议定。它是一个同步http的双向流

http://www.xmpp.org/extensions/xep-0124.html

构造方法：HttpSessionManager()

配置一个汇集执行者对异步路由传进来的数据的默认大小配置默认为60秒

注意：在默认情况下，服务支持最大254个客户端。这时候BOSH 承载着非常大的负荷，那么这就需要额外的分配一些线程池容量以供客户端及时入站点。

public HttpSessionManager() {
        this.sessionManager = SessionManager.getInstance();
        
        int poolSize = JiveGlobals.getIntProperty("xmpp.httpbind.worker.threads", 
				JiveGlobals.getIntProperty("xmpp.client.processing.threads", 16));
        int keepAlive = JiveGlobals.getIntProperty("xmpp.httpbind.worker.timeout", 60);

        sendPacketPool = new ThreadPoolExecutor(poolSize, poolSize, keepAlive, TimeUnit.SECONDS, 
			new LinkedBlockingQueue<Runnable>(), // unbounded task queue
	        new ThreadFactory() { // custom thread factory for BOSH workers
	            final AtomicInteger counter = new AtomicInteger(1);
	            public Thread newThread(Runnable runnable) {
	                Thread thread = new Thread(Thread.currentThread().getThreadGroup(), runnable,
	                                    "httpbind-worker-" + counter.getAndIncrement());
	                thread.setDaemon(true);
	                return thread;
	            }
	    	});
    }

ThreadPoolExecutor该线程池配置了：池中所保持的线程数和最大线程数均为poolSize(16)，

keepAlive多余空闲线程等待心任务的的最长时间。

TimeUnit.SECONDS：参数的时间单位

newLinkedBlockingQueue<Runnable>()：执行前保持的队列，此队列仅保持由execute 方法提交的 Runnable 任务。

ThreadFactory：执行程序创建新线程时使用的工厂。

启动sessionManager

public void start() {
        inactivityTask = new HttpSessionReaper();
        TaskEngine.getInstance().schedule(inactivityTask, 30 * JiveConstants.SECOND,
                30 * JiveConstants.SECOND);
        sendPacketPool.prestartCoreThread();
    }

HttpSessionReaper该类是个记时任务类。覆盖了TimerTask中的run方法。我们先看看该方法的内容

public void run() {
            long currentTime = System.currentTimeMillis();
            for (HttpSession session : sessionMap.values()) {
                long lastActive = currentTime - session.getLastActivity();
                if (Log.isDebugEnabled()) {
                	Log.debug("Session was last active " + lastActive + " ms ago: " + session.getAddress());
                }
                if (lastActive > session.getInactivityTimeout() * JiveConstants.SECOND) {
                	Log.info("Closing idle session: " + session.getAddress());
                    session.close();
                }

            }
        }

session.getLastActivity()：这个方法以毫秒为时间单位返回关闭http连接的时间。

getInactivityTimeout() 这个方法以秒为单位返回不活跃或被终止会话时间

这里用系统时间减去http关闭连接时间。也就是说在关闭连接的时间与系统当先的这段时间，该会话在服务端系统就是一个闲置的状态。下面的方法：

if (lastActive > session.getInactivityTimeout() * JiveConstants.SECOND) {
                	Log.info("Closing idle session: " + session.getAddress());
                    session.close();
                }

当这个闲置时间大于这个不活跃或被关闭连接的时候，这里就执行session.close()方法来结束这个会话。

回过头来，再看start()方法。

 TaskEngine.getInstance().schedule(inactivityTask, 30 * JiveConstants.SECOND,30 * JiveConstants.SECOND);

TaskEngine该类使用工作线程来执行任务。它还可以安排任务执行的时间，该类模拟了ExecutorService和Timer。任何TimerTask,按预定计划运行在未来将会被自动运行使用线程执行器的线程池。这意味着标准的限制,TimerTasks并不适用快速运行。

Schedule()方法：

安排指定重复任务（固定的延迟执行）。Subsequent executions take place at approximatelyregular intervals separated by the specified period.

在固定延迟执行,每个执行计划相对于实际执行时间前执行。如果一个执行延迟由于任何原因(如垃圾回收或其他后台活动),后续执行也将推迟。从长远来看,执行的频率通常是略低于指定的周期的倒数(假设系统时钟底层对象等(长)是准确的)。

固定延迟执行适当的重复出现的活动,要求“smoothness“换句话说,它是适合他们的活动,更重要的是要保持频率准确在短期内比从长远来看。这包括大多数动画任务,如闪烁的光标定期。它还包括任务中执行常规的活动在回应人类输入,如自动重复字符只要一个关键是压低频率。

调用该方法的三个参数：

inactivityTask：需要调度的任务

30 * JiveConstants.SECOND：执行任务之前延迟的毫秒数

30 * JiveConstants.SECOND：连续执行任务的间隔毫秒

最后一步：

sendPacketPool.prestartCoreThread();

该方法启动核心线程，使其处于等待工作的空闲状态。仅当执行新任务时，此操作才重写默认的启动核心线程策略。

HttpBindServer

public void setHttpBindPorts(int unsecurePort, int securePort) throws Exception {
        changeHttpBindPorts(unsecurePort, securePort);
        bindPort = unsecurePort;
        bindSecurePort = securePort;
        if (unsecurePort != HTTP_BIND_PORT_DEFAULT) {
            JiveGlobals.setProperty(HTTP_BIND_PORT, String.valueOf(unsecurePort));
        }
        else {
            JiveGlobals.deleteProperty(HTTP_BIND_PORT);
        }
        if (securePort != HTTP_BIND_SECURE_PORT_DEFAULT) {
            JiveGlobals.setProperty(HTTP_BIND_SECURE_PORT, String.valueOf(securePort));
        }
        else {
            JiveGlobals.deleteProperty(HTTP_BIND_SECURE_PORT);
        }
    }

首先看看changeHttpBindPorts(unsecurePort, securePort)方法：

private synchronized void changeHttpBindPorts(int unsecurePort, int securePort)
            throws Exception {
        .......

        if (httpBindServer != null) {
            try {
                httpBindServer.stop();
            }
            catch (Exception e) {
                Log.error("Error stopping http bind server", e);
            }
        }

        configureHttpBindServer(unsecurePort, securePort);
        httpBindServer.start();
    }

在这段代码里面主要设计到的有两个方法

方法一：confingureHttpBindServer(unsecurePort,securePort)

该方法主要为一个httpbind指定两个端口：

一个是：正常httpbind服务端口，7070另一个为：TLS安全HTTP绑定端口。7443

该方法中用到了一个jetty类QueuedThreadPool。

解释下一个类。该类是jetty的一个线程池，它实现了org.eclipse.jetty.util.thread.ThreadPool接口，并继承org.eclipse.jetty.util.component.AbstractLifeCycle。

在里是为了给该线程池设置一线程名称。

然后创建连接，of与jetty中创建连接用到了SelectChannelConnector。它继承了

AbstractNIOConnector。它选择NIO连接器。这个连接器使用NIO缓冲器与非有效阻止线程模型。直接使用NIO缓冲区和线程只分配给连接请求。同步是用来模拟阻塞为servletAPI,和任何冲内容尽头的请求处理是异步写的。这个连接器是最好的用于当有许多空闲时间的连接。

使用延续,支持无线的等待。如果一个过滤器或servlet返回后调用Continuation.suspend()或者延续暂停期间抛出一个运行时异常时从一个调用Continuation.undispatch(),Jetty将不会发送响应给客户端。相反,线程被释放和延续是放置在定时器队列。如果连续超时过期,或它的恢复方法被调用,然后再次请求分配给一个线程和请求重试。这种方法的局限性是,请求内容不可用于重试请求,因此如果可能应该阅读后的延续或保存为请求属性或相关的对象实例的延续。

createBoshHandler()

private void createBoshHandler(ContextHandlerCollection contexts, String boshPath)
    {
        ServletContextHandler context = new ServletContextHandler(contexts, boshPath, ServletContextHandler.SESSIONS);
        context.addServlet(new ServletHolder(new HttpBindServlet()),"/*");
    }

 private void createCrossDomainHandler(ContextHandlerCollection contexts, String crossPath)
    {
        ServletContextHandler context = new ServletContextHandler(contexts, crossPath, ServletContextHandler.SESSIONS);
        context.addServlet(new ServletHolder(new FlashCrossDomainServlet()),"/crossdomain.xml");
    }

loadStaticDirectory()

最后一步：

httpBindServer.start()

Script Syntax(脚本语法)

介绍

一些运行时环境的跨域安全限制，允许客户端访问纯XML文本，只有当它接收到一个特定的服务器（例如，Web客户端的主机名下载）。出人意料的是，同样的环境通常允许客户端接收和执行来自任何服务器的脚本。安全注意事项以下部分描述了重大部署脚本语法风险

Script Syntax

HTTP/1.1 200 OK
Content-Type: text/javascript; charset=utf-8
Cache-Control: no-store
Cache-Control: no-cache
Pragma: no-cache
Content-Length: 212

_BOSH_("<body type='terminate' condition='item-not-found'
        xmlns='http://jabber.org/protocol/httpbind'/>")

GET /webclient?%3Cbody%20content='text/xml;%20charset=utf-8'%20
    hold='1'%20rid='1573741820'%20to='jabber.org'%20
    route='xmpp:jabber.org:9999'%20secure='true'%20ver='1.6'%20
    wait='60'%20xml:lang='en'%20
    xmlns='http://jabber.org/protocol/httpbind'/%3E
    HTTP/1.1
Host: httpcm.jabber.org
Accept-Encoding: gzip, deflate
Cache-Control: no-store
Cache-Control: no-cache
Pragma: no-cache
Content-Length: 0

GET /webclient?%3Cbody%20rid='1249243562'%20sid='SomeSID'%20
    xmlns='http://jabber.org/protocol/httpbind'%3E%3C
    message%20to='friend@example.com'%20xmlns='jabber:client'%3E%3C
    body%3EI%20said%20%22Hi!%22%3C/body%3E%3C/message%3E%3C/body%3E
    HTTP/1.1
Host: httpcm.jabber.org
Accept-Encoding: gzip, deflate
Cache-Control: no-store
Cache-Control: no-cache
Pragma: no-cache
Content-Length: 0

字符
	Unicode代码点值
	转义序列

"	U+0022	\"
Line Feed (New Line)	U+000A	\n
Carriage Return	U+000D	\r
Line Separator	U+2028	\u2028
Paragraph Separator	U+2029	\u2029
\	U+005C	\\

OpenFire源码学习之十二：HttpBind&Script Syntax

标签：httpbind   script syntax   openfire   socket   im通讯   

原文地址：http://blog.csdn.net/huwenfeng_2011/article/details/43417343