如何做一个最完美的实时数据传输程序

               如何做一个最完美的实时数据传输程序  

   年底公司没什么事，看到同事们都在刷各个不同的二手火车票网站，因为要得到最新信息要不停的F5，所以我想做一个实时更新最新数据的web程序，反正也没什么事情做。
    我的思路是：利用ajax每秒访问数据库一次，如果有最新的数据就返回最新数据，完成小demo，功能也实现了，但是同事觉得我的思路不好，因为不停的访问数据库会影响效率，公司是做税务的，效率总是放在第一位的。
     同事也提供了一个思路，利用ajax每秒访问后台但是不允许数据库，利用oracle的触发器，如果有新数据插入就允许访问相关数据库数据。
     不知道能否用触发器控制一段java代码，这个暂且不说，就算可以实现效率会提高多少?
     不知道大家是否有什么看法和新的思路，怎么样才能做一个最完美的实时数据传输程序。






ps：大家新年快乐，希望那些没买到票的都能买到票，能够顺利的回家过年。

评论

7 楼 hax 2008-03-03  

如果你只是担心数据库的压力，而不在乎web服务器的压力（通常确实如此），那没有必要用其他技术，只需要在web服务器上合理的做缓存就可以了，比如你的web服务器程序保持cache是5秒，只有超过5秒才会重新访问一次数据库。

6 楼 mickeyccq 2008-03-03  

利用二楼的技术应该可以了。DWR２.０就是用的Comet技术进行事件触发推送消息　的。

5 楼 mickeyccq 2008-03-03  

利用二楼的技术应该可以了。DWR２.０就是用的Comet技术进行事件触发推送消息　的。

4 楼 Sing 2008-02-15  

你试http长连接Comet服务器推技术,这个是不断地建立30秒长的连接,相当于跟服务器建立了socket连接,是属于实时数据提取的.
http://www.examda.com/Java/zhuangye/20070908/113416646.html

3 楼 rasonyang 2008-02-15  

JavaScript可以通过Extjs实现OBserver模式
然后，就是通过Applet或者DWR Reverse ajax,
让Server fire json Event让javascript onEvent

2 楼 一杯白开水 2008-02-07  

ls一下子就一片代码, 像我这样没用过ajax的人看得累啊.
能不能把你的实现原理描述一下?

1 楼 rasonyang 2008-02-02  

<p>我的实现思路如下：</p><p> 实现通过DWR Reverse Ajax调用EXTJS的Observable Class(Java CODE)</p><p>Collection&lt;ScriptSession&gt; sessions = serverContext.getScriptSessionsByPage(pageUrl);<br/>        logger.debug("the page:{} url's session size is {}", pageUrl,sessions.size());<br/>        ScriptBuffer script = new ScriptBuffer();<br/>        script.appendScript("cti.fireVoiceEvent(")<br/>          .appendData(event)<br/>          .appendScript(");");<br/>        logger.debug("the script is {}", script);<br/>        for(ScriptSession session:sessions){<br/>            logger.warn("session id is {}", session.getId());<br/>            session.addScript(script);<br/>        } </p><p>cti.js如下：</p><p>Ext.namespace('cti');<br/>cti.Voice = function(){<br/>        this.addEvents({<br/>        "dialing" : true,<br/>        "ringing" : true,<br/>        "established" : true,<br/>        "released" : true<br/>    });<br/>    <br/>    <br/>        <br/>};<br/>Ext.extend(cti.Voice, Ext.util.Observable);<br/>cti.VoiceCallBack = new cti.Voice(); <br/>cti.fireVoiceEvent = function(event){<br/>    var runFireEvent = cti.VoiceCallBack.fireEvent.bind(cti.VoiceCallBack);<br/>    runFireEvent(event.name,event);<br/>} </p><p> </p><p>然后在Voice.js处理，各种Event事件如下：</p><p>Ext.onReady(function(){<br/>    <br/>    <br/>    <br/>    var targetDN = Ext.get('targetDN');<br/>    var thisDN = Ext.get('thisDN');<br/>    var connId = Ext.get('connId');<br/>    <br/>    //make call<br/>    var makeCallButton = Ext.get('makeCallButton');<br/>    var onMakeCall = function() {<br/>        cti_voiceService.makeCall(thisDN.getValue(),targetDN.getValue());<br/>    };<br/>    <br/>    makeCallButton.on('click',onMakeCall);<br/>    <br/>    //answer call<br/>    var answerButton = Ext.get('answerButton');<br/>    var onAnswer = function() {<br/>        cti_voiceService.answer(thisDN.getValue(),connId.getValue());<br/>    };<br/>    <br/>    answerButton.on('click',onAnswer);<br/>    <br/>    //release call<br/>    var releaseButton = Ext.get('releaseButton');<br/>    var onRelease = function() {<br/>        cti_voiceService.release(thisDN.getValue(),connId.getValue());<br/>    };<br/>    <br/>    releaseButton.on('click',onRelease);<br/>    <br/>    //logout<br/>    var logoutButton = Ext.get('logoutButton');<br/>    var onLogout = function() {<br/>        cti_voiceService.release(thisDN.getValue(),connId.getValue());<br/>        cti_voiceService.logout(thisDN.getValue());<br/>    };<br/>    <br/>    logoutButton.on('click',onLogout);<br/>    <br/>    Ext.EventManager.on(window, 'unload', function() {<br/>       cti_voiceService.release(thisDN.getValue(),connId.getValue());<br/>        cti_voiceService.logout(thisDN.getValue());<br/>    });  <br/><br/>    <br/>    //onRinging Event Handler</p><p> var onRinging = function(ev){</p><p>     cti.onStateChange(ev); </p><p>     document.voice.connId.value = ev.connID;<br/>        document.voice.thisDN.value = ev.thisDN;<br/>        document.voice.answerButton.disabled = false;<br/>        document.voice.releaseButton.disabled = true;<br/>    };<br/>    <br/>    cti.VoiceCallBack.on('ringing',onRinging);<br/>    </p><p> //onDialing  Event Handler<br/>    var onDialing = function(ev){<br/>        cti.onStateChange(ev);<br/>        document.voice.connId.value = ev.connID;<br/>        document.voice.answerButton.disabled = true;<br/>        document.voice.releaseButton.disabled = true;<br/>    };<br/>    <br/>    cti.VoiceCallBack.on('dialing',onDialing);<br/>    <br/>    var onEstablished = function(ev){<br/>        cti.onStateChange(ev);<br/>        document.voice.connId.value = ev.connID;<br/>        document.voice.answerButton.disabled = true;<br/>        document.voice.releaseButton.disabled = false;<br/>    };<br/>    <br/>    cti.VoiceCallBack.on('established',onEstablished);<br/>    <br/>    var onReleased = function(ev){<br/>        cti.onStateChange(ev);<br/>        document.voice.connId.value = ev.connID;<br/>        document.voice.thisDN.value = ev.thisDN;<br/>        document.voice.answerButton.disabled = true;<br/>        document.voice.releaseButton.disabled = true;<br/>    };<br/>    <br/>    cti.VoiceCallBack.on('released',onReleased);<br/>    <br/>    <br/>    cti.reverseAjax();<br/>    <br/>    <br/>    <br/>    <br/>})</p><p> </p><p>这只是其中一种实现方式而已。Reverse ajax还可以通过NIO Socket向IE/FF的Applet Socket Client发送JSon Event，由Applet执行当前页面的fireEvent。</p><p>可以通过Spring，配置不同的Reverse ajax实现方式。如果有什么不理解的，请随时找我。 [e-mail]</p>