服务器推技术研究Comet

服务器推技术

最近参与的一个关于股票的项目,有这样一个需求。服务器需要主动推送给客户端消息。这和传统的Web模式不同。传统的Web系统,客户端和服务器的交互是这样的:

客户端先和服务器建立一个TCP连接,然后客户端开始发送数据,服务器端接受数据,并且根据请求去反馈相应的信息,然后服务器终止TCP连接。

现在的HTTP1.1版本都默认Connection:keep-alive 。就是所谓的长连接,在服务器返回客户端信息之后,服务器端不会立刻断开连接,而是保持连接,直到服务器设定Timeout时间限制为止。当然keep-alive 要长期占用服务器的一个TCP 通道,占用服务器的资源。

而对与一些HTTP1.0版本是不识别keep-alive的,所以设置了keep-alive是没有用的。在实际使用中,HTTP头部有了Keep-Alive这个值并不代表一定会使用长连接。

那么如何使服务器和客户端保持长连接,让服务器接受到数据之后就立刻发送给客户端呢?

一,使用ajax长轮询,与服务器保持长连接。

二,使用iframe标签,后台不断输出代码到前端。

三,webSocket方法。

我总结了一下,大体上可以分为上面三类:

1.ajax长轮询:

实际上就是前端,不停连续的发送请求给后端,这样就可以保持前端和后端的连接了。当然,这种暴力的方式也分好和坏。如果你在前端里,写一个while循环,向后端发送ajax请求,那就是这样的情况,前一个请求,后端还没有处理完,另一个请求就发送过来了,请求不断的发送,有很多请求就被搁置,然后阻塞在那里直到自动关闭。这样是最消耗服务器资源的。当然我们可以改善一下:

	$.ajax({
		
			url:'mydata',
			dataType: 'json',
			method:'post',
			success:function(data){
			//alert(data);
			
			$("#hi").append("姓名:"+data.name+"  性别:"+data.sex);
			conn1();
	
			},
			error:function(e){
				conn1();
			
			}
		});

这样的请求就变成,前端发送了请求,直到有数据从后端传送过来,我才继续发送请求。或者我的请求一直在搁置,或者发生错误了,我再发送请求。这样的话就大大减少了前端向后端发送请求的次数,比暴力循环优化了很多。

2.iframe 长连接。

其实iframe标签,可以理解为文档中的文档,就是在html页面中,iframe来执行后端传过来的代码,相当于在html中嵌入一段需要执行的代码。那么利用iframe这个标签,我们可以这样实现长连接。

前端发送一个请求到后端,后端然后开一个循环,不断的向前端的iframe中输出代码,然后iframe执行这段代码,来输出信息。

这里就不想写代码了。

其实这两种方式,前者是让前端死循环,后者是让后端死循环。后端的话,当然可以去开一个线程执行死循环。

3.webSocket

是一种新技术,在客户端和服务器端建立Socket连接,这样前端需要安装flash去执行Socket。这样的方式,前后端可以随心所欲传送数据。网页游戏就是这种方式。

接下来重点介绍Pushlet 框架。

Pushlet框架,百度上说,用了ajax轮询和iframe隐藏帧两种方式实现了服务器推技术。

https://github.com/SilentCC/MyProgramming/blob/master/README.md

我的Git中的WebComet中有源码。下面来看下如何使用。

可以看到目录结构是这样的

我们需要pushlet.jar    log4j.properties   pushlet.properties    sources.properties    和aja-pushlet-client.js 这四个文件,在源代码包里都有。

我们需要再web.xml中配置文件

   <servlet>  
        <servlet-name>pushlet</servlet-name>  
        <servlet-class>nl.justobjects.pushlet.servlet.Pushlet</servlet-class>  
        <load-on-startup>3</load-on-startup>  
    </servlet>
    
     <servlet-mapping>  
        <servlet-name>pushlet</servlet-name>  
        <url-pattern>/pushlet.srv</url-pattern>  
    </servlet-mapping>

然后开始写pushlet的核心类

package com;

import java.io.Serializable;
import java.io.UnsupportedEncodingException;
import sun.rmi.runtime.Log;
import nl.justobjects.pushlet.core.Dispatcher;
import nl.justobjects.pushlet.core.Event;
import nl.justobjects.pushlet.core.EventPullSource;
import nl.justobjects.pushlet.*;
import nl.justobjects.pushlet.core.EventSource;

public class HelloWorldPushlet implements Serializable{
	
	static public class HwPlushlet extends EventPullSource{
		
		protected long getSleepTime(){
			
			return 3000;
		}
		
		public Event pullEvent(){
			
			Event event = Event.createDataEvent("/cuige/he");
			event.setField("mess", "hello,world!Plushlet!");
			//System.out.println("ok");
			return event;
		}
		
		
	}
	
	static public class HsPlushlet implements EventSource{
		
		public void pullEvent(String message){
			
			Event event = Event.createDataEvent("/suige/he");
			event.setField("mess", message);
			Dispatcher.getInstance().multicast(event);
		}

		public void activate() {
			// TODO Auto-generated method stub
			
		}

		public void passivate() {
			// TODO Auto-generated method stub
			
		}

		public void stop() {
			// TODO Auto-generated method stub
			
		}
		
	}
	
static public class HsPlushlet2 implements EventSource{
		
		public void pullEvent(String message){
			
			Event event = Event.createDataEvent("/cuige/he");
			event.setField("mes", message);
			Dispatcher.getInstance().multicast(event);
		}

		public void activate() {
			// TODO Auto-generated method stub
			
		}

		public void passivate() {
			// TODO Auto-generated method stub
			
		}

		public void stop() {
			// TODO Auto-generated method stub
			
		}
		
	}
	
	

}

上面这个类是我们自己写的pushlet 的核心类。

在类中,我们有两种方式可以向前端发送信息:

1.继承EventPullSource 类,

在子类中,我们可以设置getSleepTime() 来设置服务器每隔多长时间发送一组数据到前端。

pullEvent是传播数据的方法,在子类中不能有参数

2.实现EventSouce 接口。

pullEvent可以传入参数。实现EventSouce的类,可以在服务器端任何需要的地方去使用~,这样的话我们可以在需要的时候传入需要的参数,然后再发送数据到前端

创建event

Event event = Event.createDataEvent("/cuige/he"); 
event.setField("mes", message);

广播event

			Dispatcher.getInstance().multicast(event);

这样在需要的地方定义类对象,再调用就好了

在前端的话我们可以:

<script type="text/javascript" src="ajax-pushlet-client.js"></script>
	<script type="text/javascript">
	
	
		function conn2(){
	
		PL._init();
		
		
		
		PL.joinListen('/suige/he');
		alert("ok");
		}
	
		
		function onData(event){ 
		
		alert("ok");
		var data =JSON.parse(event.get("mess"));
		
		$("#hi2").append("姓名:"+data.name+"性别:"+data.sex);
		
		
		}
		
	</script>

PL._init() 是初始化客户端,

PL.joinListen('/suige/he') 是告诉高科端监听哪个event.

function onData(event){} 就是接受数据的函数。

这里我们还要配置数据源,根据我们写的主类,在sources.properties  中设置

source1=com.HelloWorldPushlet$HsPlushlet
source2=com.HelloWorldPushlet$HsPlushlet2

这样的话,我们在一个界面只能监听一个全局的消息。怎么在一个界面的两个地方接受不同的数据源呢?

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏不忘初心

一起看看VIM著名补全插件YouCompleteMe的架构和实现

YouCompleteMe是vim上最著名的插件之一,对于长期使用Linux和vim进行服务端开发的技术人员来说或多或少都有耳闻。

8171
来自专栏Java帮帮-微信公众号-技术文章全总结

Python常见面试题【悟空教程】

1.MySQL 数据库总结 MySQL 可以建多少个数据库,理论上是没有限制的,每一个数据库可以有上亿的对象,但是一般基于硬件要求、效率问题一般不超过64个, ...

1882
来自专栏Golang语言社区

goroutine背后的系统知识

Go语言从诞生到普及已经三年了,先行者大都是Web开发的背景,也有了一些普及型的书籍,可系统开发背景的人在学习这些书籍的时候,总有语焉不详的感觉,网上也有若干流...

2865
来自专栏Java架构

前沪江高级架构师学习笔记分享:分布式框架设计与实现

2046
来自专栏Puppeteer学习

一步一步学Vue(七)

1673
来自专栏Golang语言社区

Goroutine背后的系统知识

Go语言从诞生到普及已经三年了,先行者大都是Web开发的背景,也有了一些普及型的书籍,可系统开发背景的人在学习这些书籍的时候,总有语焉不详的感觉,网上也有若干流...

3556
来自专栏智能算法

Python学习(九)---- python中的线程

原文地址: https://blog.csdn.net/fgf00/article/details/52773459 编辑:智能算法,欢迎关注! 上期我们一起学...

1672
来自专栏Golang语言社区

goroutine背后的系统知识

Go语言从诞生到普及已经三年了,先行者大都是Web开发的背景,也有了一些普及型的书籍,可系统开发背景的人在学习这些书籍的时候,总有语焉不详的感觉,网上也有若干流...

3524
来自专栏后台全栈之路

基于汇编的 C/C++ 协程 - 实现

将 libco 和 libevent 两者的功能糅合起来,所以我把我的工程,命名为 libcoevent,意为 “基于 libevent 的同步协程服务器编程框...

5813
来自专栏和蔼的张星的图像处理专栏

1.Win10+VsCode的C/CPP编译环境搭建

我是从开始学C++的时候就一直用的是visual studio,毕竟宇宙第一IDE,写和调试都是超级方便快捷,唯一的缺点可能就是启动慢一点。 之前电脑没有换固...

8346

扫码关注云+社区

领取腾讯云代金券