开源Websocket服务器CshBBrain股指推送应用使用说明

1.从github 或google code 下载CshBBrain 的1.0.2版本源代码包。下载地址：

 

GitHub下载地址：https://github.com/CshBBrain/CshBBrain/downloads

googlecode下载地址：http://code.google.com/p/cshbbrain/downloads/list

2.将源代码包解压导入到eclipse中，编译通过。

3.找到src/com/jason/server/ws/ 目录下的 StockServer.java 文件，点击运行。

4.找到test/stock目录下的index.html文件，使用chrome浏览器打开此文件。

5.看到服务器后台有如下输出：

 

17:16:51,000  INFO MasterServer:192 - [{"raw":"1","name":"上证指数","points":"2104.932","change":"2.06","changeScale":"0.10%"},{"raw":"2","name":"深证成指","points":"8650.191","change":"-14.90","changeScale":"-0.17%"},{"raw":"2","name":"纳斯达克","points":"3044.12","change":"-5.30","changeScale":"-0.17%"},{"raw":"2","name":"日经指数","points":"8534.12","change":"-12.66","changeScale":"-0.15%"},{"raw":"1","name":"道琼斯","points":"13328.85","change":"2.46","changeScale":"0.02%"},{"raw":"1","name":"新加坡海峡时报指数","points":"3041.75","change":"9.09","changeScale":"0.30%"},{"raw":"2","name":"台湾台北指数","points":"7437.04","change":"-14.68","changeScale":"-0.20%"},{"raw":"1","name":"恒生指数","points":"21136.43","change":"137.38","changeScale":"0.65%"}]

[{"raw":"1","name":"上证指数","points":"2104.932","change":"2.06","changeScale":"0.10%"},{"raw":"2","name":"深证成指","points":"8650.191","change":"-14.90","changeScale":"-0.17%"},{"raw":"2","name":"纳斯达克","points":"3044.12","change":"-5.30","changeScale":"-0.17%"},{"raw":"2","name":"日经指数","points":"8534.12","change":"-12.66","changeScale":"-0.15%"},{"raw":"1","name":"道琼斯","points":"13328.85","change":"2.46","changeScale":"0.02%"},{"raw":"1","name":"新加坡海峡时报指数","points":"3041.75","change":"9.09","changeScale":"0.30%"},{"raw":"2","name":"台湾台北指数","points":"7437.04","change":"-14.68","changeScale":"-0.20%"},{"raw":"1","name":"恒生指数","points":"21136.43","change":"137.38","changeScale":"0.65%"}]

浏览器中呈现如下图所示就表示启动成功。

服务器隔3秒采集一次最新的股指，并把最新股指推送到客户端。客户端的股指隔3秒滚动更新一次。

评论

5 楼 CshBBrain 2012-11-13  

ouyangwanbin 写道

我打开两个窗口，只有其中的一个能不断的接收到推送消息，另外一个则无法接收到推送消息了

http://cshbbrain.iteye.com/blog/1724348
开源WebSocket服务器项目宝贝鱼CshBBrain V4.0.1 和 V2.0.2发布

更新的功能列表如下：
1.解决开启广播消息开关时，不能同时接入2个客户端的重大缺陷。
2.对广播消息做了重大优化，从以前一个线程发送广播消息进化到使用工作线程池中的线程并行的发送广播消息。
3.发送给所有客户端的广播消息共享一个消息的内容，避免大量重复的消息编码缓存处理工作，有效的提升广播消息的效率。
4.对框架的响应写回机制做了重大优化，服务器工作线程接收完消息，进行解码、业务处理和编码，以前是注册一个回写事件；优化后的处理方式时工作线程首先调用
回写函数向客户端回写内容，如果回写的内容不多，在工作线程中就处理完了，就避免了线程的切换，响应速度更快了；如果回写的内容多，工作线程的回写调用不能写
完全部内容，然后再注册回写事件，让Selector继续完成剩余内容的回写工作。优化后对于要求快速响应，消息内容短小的应用效果明细。

源代码已经更新到googlecode:http://code.google.com/p/cshbbrain/downloads/list
github:https://github.com/CshBBrain/CshBBrain/downloads

基于AIO的版本在github上单独创建了一个源代码库：https://github.com/CshBBrain/CshBBrainAIO

4 楼 CshBBrain 2012-11-06  

ouyangwanbin 写道

我打开两个窗口，只有其中的一个能不断的接收到推送消息，另外一个则无法接收到推送消息了

我这边没有遇到这种情况，我抽时间 再测试测试。

3 楼 ouyangwanbin 2012-11-06  

我打开两个窗口，只有其中的一个能不断的接收到推送消息，另外一个则无法接收到推送消息了

2 楼 CshBBrain 2012-10-14  

affan 写道

楼主, 关于Java nio， 多线程，并发，网络编程 如何学习啊？？？？
刚毕业参加工作 现在想深入学习 很迷茫啊！还请楼主赐教！！！！

http://cshbbrain.iteye.com/blog/1025508
这篇博文讲了些东西，我在这篇博文后面上传的附件 JAVA_NIO_全书.pdf  可能对你很有帮助，强烈建议你仔细去读一读。另外开源Websocket服务器CshBBrain的源代码你可以自己多去读下，代码里面的注释还是比较详细的，相信对你应该有所帮助。

1 楼 affan 2012-10-14  

楼主, 关于Java nio， 多线程，并发，网络编程 如何学习啊？？？？
刚毕业参加工作 现在想深入学习 很迷茫啊！还请楼主赐教！！！！