- 浏览: 426389 次
- 性别:
- 来自: 成都
文章分类
最新评论
-
binghc:
能使用浏览器作为客户端么,用socket构建一个最简单的htt ...
HTTPS那些事 用java实现HTTPS工作原理 -
littleShyBoy:
如果是使用http client请求https的接口,http ...
HTTPS那些事 用java实现HTTPS工作原理 -
skw1975:
...
HTTPS那些事 用java实现HTTPS工作原理 -
sealinesu:
看了半天,真的是半天,总算是把这些概念都理清了,谢谢博主
spring事务传播机制实例讲解 -
wanghaozdw:
请问下,在内外层事务均是REQUIRED的情况下,内层事务抛出 ...
spring事务传播机制实例讲解
commet
感谢philip McCarthy(philmccarthy@gmail.com)
异步服务器
端事件驱动的Ajax程序
很难实现,也很难获得伸缩性。在作者的系列文章
里,Plilip McCarthy展示了一个有效的方式:
Comet模式允许您push数据
到客户端,而且Jetty
6的Continuations API让您的Comet程序对大量客户端获得高可伸缩性。您可以方便的同DWR
2使用Comet和Continuations。
随着Ajax在Web程序开发技术里建立了牢固的位置,出现了几种常见的Ajax使用模式。例如,Ajax通常用于响应用户 输入来使用新数据修改局部页面。但有时候,Web程序的用户界面需要根据偶尔的异步服务 器端事件来更新,而不需要用户动作 -- 例如,在Ajax聊天程序里显示其他用户输入的一条新消息。由于Web浏览器和服务器间的HTTP连接只能由浏览器建立,服务器不能"推"更改数据到浏览器。
Ajax程序有两个解决该问题的基本方式:浏览器每隔几秒请求服务器来获得更改,或者服务器维持与浏览器的连接并且传递数据。长连接技术称为Comet。本文展示了怎样使用Jetty服务器引擎和DWR来实现简单而高效的Comet Web程序。
为什么要Comet?
轮询方式的主要缺点是在大量客户端时产生了大量的传输浪费。每个客户端都必须有规律的请求服务器来获得更改,这是服务器资源的一个重担。最坏的情况是程序很少更新,例如Ajax邮件
收件箱。在这种情况下,大量的客户端轮询是多余的,服务器仅仅简单的响应"没有数据"。
可以通过增加轮询间隔时间来减轻服务器负荷,但是这引入了服务器事件和客户端知晓之间的延迟。当然,一个合理的折衷方案可以多数程序适用,并且轮询的工作方式也可以接受。
然而,对Comet策略的呼唤来自它可感知的高效。客户端不会产生轮询方式特有的传输浪费,一旦事件发生,就会被发布到客户端。但是维持长连接也消耗了服务器资源。当servlet位置持久的请求在等候状态时,servlet独占一个线程 。这样传统的servlet引擎就限制了Comet的伸缩性,因为客户端的数量会迅速超过服务器栈可以有效处理的线程的数量。
Jetty 6有什么不同
Jetty
6设计来处理大量并发连接,它使用Java语言的不堵塞I/O(java.nio)库并且使用优化的输出缓冲架构。Jetty也有一个处理长连接的杀手
锏:一个称为Continuations的特性。我将用一个接收请求然后等待两秒发送响应的简单servlet来示范Continuations。然后,
我将展示当服务器拥有更多的客户端时将发生什么。最后我将使用Continuations重新实现servlet,并且您将看到它们的不同。
为了让它更简单,我将限制Jetty
servlet引擎为一个单一的请求处理线程。列表1显示了相关的jetty.xml配置。事实上我需要允许在ThreadPool里总共有3个线
程:Jetty服务器本身使用一个,HTTP连接器使用一个来监听进来的请求,最后剩一个线程来执行servlet代码。
列表1. 单一servlet线程的Jetty配置
代码 <?xml version="1.0"?> |
列表2. BlockingServlet
代码
public class BlockingServlet extends HttpServlet {
public void service(HttpServletRequest req, HttpServletResponse res) throws java.io.IOException {
String reqId = req.getParameter("id");
res.setContentType("text/plain");
res.getWriter().println("Request: " + reqId + "\tstart:\t" + new
Date());
res.getWriter().flush();
try
{
Thread.sleep(2000);
} catch
(Exception e) {}
-----------------------------------------------------------
现在您可以观察几个同步请求下servlet的行为。列表3显示了使用lynx的5个并行请求时控制台的输出。命令行简单的启动5个lynx进程
,加上一个标识符序数到请求的URL。
列表3. 到BlockingServlet的几个并发请求的输出
代码 $ for i in 'seq 1 5' ; do lynx -dump
localhost:8080/blocking?id=$i & done Request: 2 start: Sun Jul 01 12:32:31 BST 2007 Request: 3 start: Sun Jul 01 12:32:33 BST 2007 Request: 4 start: Sun Jul 01 12:32:35 BST 2007 Request: 5 start: Sun Jul 01 12:32:37 BST 2007 |
现在,看看Jetty
6的Continuations特性在这种情形下是多么的有用。列表4显示了列表2的BlockingServlet使用Continuations
API重写后的样子。我将在后面解释代码。
列表4. ContinuationServlet
代码 public class ContinuationServlet extends HttpServlet { public void service(HttpServletRequest req, HttpServletResponse res) throws java.io.IOException { String reqId = req.getParameter("id"); Continuation cc = ContinuationSupport.getContinuation(req, );
res.setContentType("text/plain"); cc.suspend(2000);
res.getWriter().println("Request: " + reqId + "\tend:\t" + new
Date()); |
列表5. 到ContinuationServlet的几个并发请求的输出
代码 $ for i in 'seq 1 5' ; do lynx -dump
localhost:8080/continuation?id=$i & done Request: 3 start: Sun Jul 01 12:37:37 BST 2007 Request: 2 start: Sun Jul 01 12:37:37 BST 2007 Request: 5 start: Sun Jul 01 12:37:37 BST 2007 Request: 4 start: Sun Jul 01 12:37:37 BST 2007 |
深入Jetty的Continuations机制
理解Jetty的Continuations机制的将解释您在列表5里
看到的东西。为了使用Continuatins,Jetty必须配置为使用它的SelectChannelConnector处理请求。这个
connector构建在java.nio
API之上,允许它维持每个连接开放而不用消耗一个线程。当使用SelectChannelConnector
时,ContinuationSupport.getContinuation()提供一个
SelectChannelConnector.RetryContinuation实例(但是,您必须针对Continuation接口编程)。当在
RetryContinuation上调用suspend()时,它抛出一个特殊的运行时异常 --
RetryRequest,该异常传播到servlet外并且回溯到filter链,最后被SelectChannelConnector捕获。但是不会
发送一个异常响应给客户端,而是将请求维持在未决
Continuations队列里,则HTTP连接保持开放。这样,用来服务请求的线程返回给ThreadPool,然后又可以用来服务其他请求。
暂停的请求停留在未决 Continuations队列里直到指定的过期时间,或者在它的Continuation上调用resume()方法。当任何一个条件触发时,请求会重 新提交给servlet(通过filter链)。这样,整个请求被"重播"直到RetryRequest异常不再抛出,然后继续按正常情况执行。
列表5里的输出现在应该能理解了。对每个请求,按顺序进入到servlet的service()方法,start消息发送给应答,然后 Continuation的suspend()方法保留servlet,然后释放线程来开始下一请求。所有的5个请求迅速运行service()方法的第 一部分并马上进入暂停状态,所有的start消息在几毫秒内输出。两秒后,suspend()过期,第一个请求从未决队列里重新得到并重新提交给 ContinuationServlet。start消息第二次输出,对suspend()方法的第二次调用立即返回,然后end消息被发送给应答。然后 servlet代码执行下一个队列请求,以此类推。
所以,在BlockingServlet和ContinuationServlet两种情况下,请求被排入队列来访问 单 一的servlet线程。尽管如此,在BlockingServlet里的两秒钟暂停在servlet线程里执行 时,ContinuationServlet的暂停发生于servlet外面的SelectChannelConnector里。 ContinuationServlet全部的吞吐量会更高,因为servlet线程不会在sleep()调用时阻碍大多数时间。
-----------------------------------------------------------
让Continuations变得有用
现在您已经看到Continuations运行servlet请求暂停而不消耗线程,我需要多解释一下Continuations
API来展示怎样使用Continuations达到特殊的目的。
一个resume()方法和一个suspend()方法配对。您可以认为它们是标准的Object wait()/not ify()机制的Continuations等价物。即,suspend()维持一个Continuation直到过期或者另一个线程调用resume()。suspend()/resume()方法是使用Continuations实现真实的Comet风格服务的关键 所在。基本的模式是从当前请求维持Continuation,调用suspend(),然后等待直到您的异步时间到达,然后调用resume()并生成应答。
但是,不像编程语言里真实的语言级continuations,如Scheme,或Java语言里的wait()/notify(),在 Jetty Continuation上调用resume()并不意味着代码执行于它停止的确切位置。您已经看到,真正发生的是与Continuation相关的请求 被重播。这导致两个问题:列表4的ContinuationServlet里代码不合需要的重新执行,以及丢失状态 -- 暂停时作用域里的任何东西都丢失了。
第一个问题的解决方案是isPending()方法,如果isPending()方法的返回值为true,这意味着suspend()在前面已经 被调用过了,并且二次请求的执行不会再次接触suspend()方法。换句话说,给您的suspend()调用前的代码加上isPending()条件可 以确保它只被执行一次。Continuation也提供了一个简单的机制来保持状态:putObject(Object)和getObject()方法。 使用它们来维持一个context对象,这样当Continuation暂停时任何您需要维持的状态都可以得到保护。您也可以使用该机制作为一种在线程之 间传递事件数据的方法,后面您将看到。
写一个基于Continuations的程序
作为一个真实世界里的例子,我将开发一个基本的GPS坐标跟踪Web程序。
它将在无规律间隔内生成随机的纬度-经度对。假设生成的坐标可以为附近的公众移动位置,如拿着GPS设备马拉松运动员,成队的汽车,或者运输中的包裹位
置。有意思的部分在于我怎样告诉浏览器坐标信息。图1显示了这个简单的GPS跟踪程序的类图:
图1. 显示GPS跟踪程序主要组件的类图
首先,该程序需要生成坐标的一些东西,这是RandomWalkGenerator的工作。从一个初始坐标开始,每次对它的私有方法
generateNextCoord()的调用都从该位置随机走一步并返回一个GpsCoord对象。当初始化
时,RandomWalkGenerator创建一个线程,该线程在随机间隔内调用generateNextCoorld()方法并发送生成的坐标给任何
使用addListener()注册自己的CoordListener实例。
列表6显示了RandomWalkGenerator的循环逻辑:
列表6. RandomWalkGenerator的run()方法
代码 public void run() { try { |
列表7. ContinuationBasedTracker的内脏
代码 public GpsCoord getNextPosition(Continuation continuation, int timeoutSecs) { synchronized(this) { // wait
for next update return
(GpsCoord)continuation.getObject(); public void onCoord(GpsCoord gpsCoord) { synchronized(this) {
continuation.setObject(pgsCoord);
pendingContinuations.clear(); |
-----------------------------------------------------------
当客户端在Continuation里调用getNextPosition()时,isPending()方法检查这次请求不是重试,然后添加它 到一个等待坐标的Continuations集合里,然后Continuation被暂停。同时,onCoord -- 当生成新坐标时调用 -- 简单的循环每个未决Continuations,为它们设置 GPS 坐标,然后恢复它们。然后每个重试的请求完成getNextPosition()的执行,从Continuation得到GpsCoord并返回它给调用 者。注意这里需要同步,不仅预防pendingContinuations集合里出现不一致的状态,也确保了新添加的Continuation在它被暂停 之前不会被恢复。
谜题最后一部分是servlet代码本身,显示于列表8:
列表8. GPSTrackerServlet实现
代码 public class GpsTrackerServlet extends HttpServlet { private static final int TIMEOUT_SECS =
60; public void service(HttpServletRequest req, HttpServletResponse res) throws java.io.IOException {
Continuation c ContinuationSupport.getContinuation(req, ); String
json = new Jsonifier().toJson(position); |
列表9. GPSTrackerServlet输出
代码 $ for i in 'seq 1 5' ; do lynx -dump localhost:8080/tracker
& done |
创建一个Comet客户端
现在您已经看到Continuations怎样用于创建非阻塞Web服务,您可能想知道怎样创建客户端代码来使用它。一个Comet客户端需要:
1. 维持一个XMLHttpRequest连接直到接收应答.
2. 分派应答给合适的JavaScript处理者.
3. 立即建立一个新连接.
更高级的Comet可以在客户端和服务器使用合适的路由机制来使用一个连接来从多个不同的服务推数据到浏览器。一个可能性为使用JavaScript库如Dojo等写客户端代码来提供基于Comet的请求机制,形如dojo.io.comet。
尽管如此,如果您正在使用Java作为服务器语言,在客户端和服务器端得到高级Comet支持的更好的方式是使用DWR 2。如果您不熟悉DWR,您可以该系列的第3部分,"Ajax with Direct Web Remoting"。DWR透明的提供一个HTTP-RPC传输层,暴露您的Java对象来使用JavaScript代码调用。DWR生成客户端代理,自 动marshall和unmarshall数据,处理安全问题,提供一个便利的客户端辅助库,并且对所有主要的浏览器工作。
DWR 2:反转Ajax
DWR
2新引入的概念为反转Ajax。该机制将服务端事件"推"给客户端。客户端DWR代码透明的处理连接建立和应答解析,所以从开发人员的角度来看,事件可以从服务端Java代码简单的发布到客户端。
DWR可以配置使用3个不同的机制来反转Ajax。一种是我们熟悉的轮询方式。第二种方式称为piggyback,它不创建任何到服务器的连接, 而是等待直到另一个DWR服务调用发生并piggyback未决事件到该请求应答。这可以获得高效率但是意味着客户端事件通知被延迟直到客户端作出一个不 相干的调用。最后一种机制使用Comet风格的长连接。最好的是,当DWR运行在Jetty下并且使用Continuations来获得非阻塞Comet 时可以自动检测事件。
我将修改我的GPS例子来使用DWR 2反转Ajax。同时,您将看到反转Ajax怎样工作的更多细节。
我不再需要我的servlet。DWR提供了一个control ler servlet,它协调客户端请求直接访问Java对象。我也不再需要显示处理Continuations,因为DWR在幕后处理了这些。所以我只需要一个新的CoordListener实现来发布坐标更新到任何客户端浏览器。
一个称为ServerContext的接口提供DWR的反转Ajax魔法。ServerContext知道当前查看一个给定页面的所有Web客户
端并且可以提供一个ScriptSession来与每个客户端交流。ScriptSession用来从Java代码推JavaScript片段到客户端。
列表10显示了ReverseAjaxTracker怎样响应坐标通知,以及使用它们来生成客户端updateCoordinate()方法调用。注意如
果一个合适的转换器是可用的,则DWR的ScriptBuffer对象的appendData()调用会自动marshall一个Java对象到
JSON,。
列表10. ReverseAjaxTracker里的通知回调方法
代码 public void onCoord(GpsCoord gpsCoord) { // Generate JavaScriptcode to call
client-side // Push script out to clients viewing the
page for (ScriptSession session : sessions)
{ |
我也需要告诉DWR怎样从GpsCoord
beans来marshall数据到JSON。由于GpsCoord是一个简单对象,DWR基于反射的BeanConverter足够。
列表11显示了ReverseAjaxTracker配置。
列表11. ReverseAjaxTracker的DWR配置
代码 <dwr>
<convert converter="bean"
match="developerworks.jetty6.gpstracker.GpsCoord"/> |
-----------------------------------------------------------
create元素的javascript元素指定了DWR用来暴露tracker作为一个JavaScript对象的名字。但是,在这里,我的客户端代码不会使用它,而是从tracker推数据给它。同时,也需要在web
.xml里做一些额外的配置来让DWR使用反转Ajax,见列表12。
列表12. DwrServlet的web.xml配置
代码 <servlet> |
最后,我需要实现从DWR调用的客户端JavaScript方法。回调方法updateCoordinate()被传递一个JSON形式的
GpsCoord对象,它由DWR的BeanConverter自动序列化。这个方法仅仅从坐标提取longitude和latitude域并通过DOM
调用添加它们到一个列表里。这在列表13里显示了,同我的页面的onload方法一起。onload包含对
dwr.engine.setActiveReverseAjax(true),这告诉DWR打开一个到服务器的持久的连接来等待回调。
列表13. 反转Ajax GPS跟踪的客户端实现
代码 window.onload = function() { function updateCoordinate(coord) { |
图2. ReverseAjaxTracker输出
使用反转Ajax创建一个事件驱动的Ajax程序是如此简单。记住,感谢DWR对Jetty Continuations的使用,当等待新事件到达时线程不会阻塞在服务器。
据此,很容易从Yahoo!或者Google集成一个地图窗口部件。通过改变客户端回调方法,坐标可以简单的传递到地图API,而不是直接添加到页面。图3显示了在这样的一个地图组件上DWR反转Ajax
GPS跟踪程序描绘的随机路线:
图3. 使用地图UI的ReverseAjaxTracker
结论
相关推荐
本实例主要探讨的是“消息推送实例commet4j”,这是一款基于Java的开源库,专门用于实现服务器向客户端实时推送消息的功能。它巧妙地利用了HTTP长连接(Comet技术)来避免传统的轮询方式带来的效率低下问题,极大地...
Java Comet + UDP 实现是一个在Web开发中处理实时通信的技术组合。Comet是一种服务器推送技术,主要用于构建响应式、实时的Web应用,而UDP(User Datagram Protocol)是一种无连接的传输层协议,常用于需要快速传输...
pdm 把ORACLE导出的commet 变成Name
【标题】"原创nio socket mina+javascript+flash实现commet长连接网页聊天室"揭示了一个基于Java NIO(Non-blocking I/O)的Socket通信框架Mina与JavaScript、Flash技术结合,实现COMET(Comet是使服务器向浏览器推...
*** Commet多功能网站开发***工作流程 laravel安装: 使用以下命令:composer create-project --prefer-dist laravel / laravel commet ---设置完成---- .env文件设置 提供应用名称,数据库名称,APP_URL = ...
特惠套票 ... 苏姆波多(Karmet Multi Trip,COMMET) 执照 This program is free software: you can redistribute it and/or modify it under the terms of the GNU General Public License as publis
Layihə 第一周 Nəzəriyyənimənimsəmək,GitHub-uöyrənmək 第2周 github-dafolderləriyaratmaq,artıqfayllarısilmək ... Commet-bar yaratmaq 第4周 Flex Froggybütüntapşırıqlar
- 当接收到请求时,服务器从查询字符串中获取参数,如`uname`和`commet`,并将它们添加到一个字典`dic`中。 - 使用`Newtonsoft.Json.JsonConvert.SerializeObject()`方法,将字典序列化为JSON字符串并返回给客户端...
`commet`部分则涉及到了评论功能的实现,这是社交应用中的关键组件,允许用户对feed内容进行反馈和交流。`IM`(即时通讯)可能意味着此项目还集成了基础的聊天功能,让用户能实时互动。"朋友圈等等"则暗示了应用中可能...
Linux内核是操作系统的核心部分,负责管理系统的硬件资源,提供基础服务给各种应用程序。Linux-Kernel-2.6-comment项目提供了对Linux 2.6.11.12内核源码的详尽注释,这是一份极其宝贵的学习资料,帮助开发者深入理解...