javawebsocket源码

① java怎么做websocket

package com.bpms.interfaces.communicate.paycode;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.ConnectException;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import com.unify.cc.common.CommonUtil;
public class SocketSend {
private String host = "11.1.66.193";
private int port = 2345;
private Socket client;
private SocketAddress remoteAddr;
private DataOutputStream os;
private DataInputStream is;
private int overTime = 0;
private int maxChang = 256;
private String error = ""烂卖;

/**
* 只配服务端的地址和端口
* @param host 服务备圆端IP
* @param port 服务端端口
*/
public SocketSend(String host , int port) {
this.host = host;
this.port = port;
}

/**
* 设置连接报文长度的配置
* @param host IP
* @param port 端口
* @param maxChang 指定接收饥滚逗报文长度
*/
public SocketSend(String host , int port , int maxChang) {
this.host = host;
this.port = port;
if(maxChang != 0)
this.maxChang = maxChang;
}

/**
* 设置连接连接超时的配置
* @param host IP
* @param port 端口
* @param maxChang 指定接收报文长度
* @param overTime 连接超时时间
*/
public SocketSend(String host , int port , int maxChang , int overTime) {
this.host = host;
this.port = port;
if(maxChang != 0)
this.maxChang = maxChang;
if(overTime != 0)
this.overTime = overTime;
}

/**
* 初始化参数
* @throws IOException
*/
public void init() throws IOException {
if(client == null)
client = new Socket();
remoteAddr = new InetSocketAddress(host,port); //创建客户端连接地址
try{
if(overTime != 0) {
client.connect(remoteAddr,overTime);
}
else {
client.connect(remoteAddr);
}
} catch (ConnectException e) {
error = "SocketSend - init ConnectionServicesException";
return;
}
is = new DataInputStream(client.getInputStream()); //获得服务端输出流
os = new DataOutputStream(client.getOutputStream()); //获得服务端输入流
}

/**
* 关闭连接
* @throws IOException
*/
private void close() throws IOException{
if (os != null) {
os.close();
}
if(is != null) {
is.close();
}
if(client != null) {
client.close(); //关闭连接器
}
}

/**
* 写入流
*/
public void writeMessage(byte[] byt){
try {
os.write(byt); //在服务端写入报文
os.flush();
} catch (IOException e) {
CommonUtil.debug("SocketSend - writeMessage 报文写入异常");
e.printStackTrace();
}
}
/**
* @param message 报文
* @return 返回报文
* @throws IOException , Exception
*/
public byte[] execute(byte[] byt) throws Exception{
init();
byte[] buf = null;
//连接异常不做处理
if("".equals(error)){
writeMessage(byt);
buf = new byte[maxChang];
if (is != null) {
is.read(buf);//读入数据到缓冲区
}
close();
}else {
close();
throw new Exception(error);
}
return buf;
}
}

② 学Java有哪些可以练手的项目

1.各种管理系统

源码下载（实例一）：

jsp开发完整的博研图书馆后台管理系统，不使用框架开发的，太完美了

源码下载（实例二）：

javaWeb图书馆管理系统源码mysql版本

源码下载（实例三）

GitHub - uboger/LibraryManager: JAVA GUI 图书馆管理系统

源码下载（实例四）：

java swing开发企业人事管理系统源代码下载

2.简易的聊天系统

源码下载（实例一）：

java swing开发网络聊天室群聊系统,基于java多线程socket编程

源码下载（实例二）：

java swing开发大猫聊天室源码，简单易懂，适合java swing初学者

源码下载（实例三）：

java websocket开发简单聊天室系统，实现群聊与一对一单人聊天案例

源码下载（实例四）：

jsp开发简单聊天室demo-分享

3.实现通讯录

java通讯录实现了添加删除和查找功能

源码下载（二）：

JAVA版通讯录管理系统课程设计源码

源码下载（三）：

Java Swing界面.完美设计通讯录..有需要的下

4.坦克大战

源码下载（一）：

俄罗斯方块 JAVA版

源码下载（二）：

GitHub - FieldSoft-HelloClyde/Tetris-Swing: Swing编写的俄罗斯方块

源码下载（三）：

java swing开发的俄罗斯方块游戏，包含完整代码+详细注释

5.五子棋

源码下载（一）：

Java实践（十一）——五子棋

源码下载（二）：

java swing开发的五子棋小游戏源码

源码下载（三）：

java swing开发单机版五子棋源代码下载

源码下载（四）：

Java五子棋算法和代码

6.中国象棋

源码下载（一）：Java实践（十二）——中国象棋

7.贪吃蛇

java贪吃蛇源代码 、 java贪吃蛇源代码

以上是总结出来的简单的练手项目，希望对你有帮助

③ 浏览器不支持websocket怎么办

1、新建web project。找到tomcat 7.0 lib 下的谨笑梁catalina.jar,tomcat-coyote.jar添加到项目中如下是我的目录结构。

④ java 实现长连接接受信息，发送信息

对于你这个需求，可以用当前比较热门的websocket来解决。

websocket可以实现服务端和客户端全双工通信，实时性非常好。

你可以自己搭建websocket服务，也可以使用第三方的websocket推送框架，比如【GoEasy】。

【GoEasy】目前支持java、php、python等服务端语言，同时也支持小程序、vue、uniapp等前端技术，使用起来还是非常方便的。

⑤ 实战spring-boot-starter-websocket之断网心跳续期实践

业务中需要应用到Websocket长连接进行数据传输，由于服务使用的是Zuul1.0版本，对ws协议支持较弱，后续尝试使用了 spring-boot-starter-websocket 来完成的。关于怎么集成的话网上有非常多的文章了，我就不多费口舌了。

我们目前实现的功能是可以通过WebSocket调用接口发送埋点，另外还需要监听用户离开的事件为这个埋点画上一个终止访问时间。目前测试下场景有：

前4点触发了任意操作，服务端都会监听到 DISCONNECT 离开事件。但是第5点直接断网， 服务端竟然是无感知的，这个时候产生的问题就是客户断网了，服务端是认为在线的，如果不重新联网登录的话，那么这个用户将会一直一直在线，埋点会一直计算。完了个蛋~

至于为什么断网之后，ws会认为他是在线的， 可能管道打开了之后由于断网导致断开时间发送不出去吧。

我目前能够想到比较简单的办法就是： 心跳续约

捋清了思路，大概就知道如何做了。

然后特意看了下 spring-boot-starter-websocket 的源码，发现其实他有提供此功能。

先说下如何实现:

我们是在在谨梁实现了 的配置衡颂类中重写 configureMessageBroker 方法。

比较关键就是 setTaskScheler 和 setHeartbeatValue 一个负责调度、一个负责配置间隔。
这俩要么都填要么都不填。

配置了这俩参数之后，服务启动的时候会触发一个 HeartbeatTask 线程来专门维持心跳。

我们可以看看他的流程是如何运转的。

核心任务调度类: org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.HeartbeatTask

服务端在启动的时候 SimpleBrokerMessageHandler 在初始化完成之后会回调 start 的方法，然而他会触发一个 startInternal 开始调度任务，判断依据就是有没有配置 TaskScheler ( 对应的就是配置类中的setTaskScheler )，一旦启动之后，会根据你给的心跳数组 serverHeartbeat ，来选择调度时间。

org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler

检测心跳、超过间隔则剔除祥拦运、并且定期回写心跳给客户端。

还有一点需要注意的是读的间隔时间：
假设用户网络不好，心跳漏发了一次，这个时候如果按照本次的逻辑而言，该用户的最后心跳时间肯定会超时。而它的做法是， 将设定的读超时时间 3 ，就相当于有3次机会*。

这个在创建session的时候 SessionInfo 里面就已经做好了处理:
org.springframework.messaging.simp.broker.SimpleBrokerMessageHandler.SessionInfo#SessionInfo

所以这个时候，你可能需要根据业务能够接受的时长去配置，也别忘了这个事。

还有很关键的一点就是让客户端的心跳发送间隔和服务端尽可能保持一致，不然有可能出现莫名其妙的下线情况，尽可能还是在这种地方加好日志。

好了，希望在遇到断网问题的时候，能够帮助到你。

如果有疑问请留言，我会尽快答复。

⑥ 怎样用java web和websocket实现网页即时通讯

原理

WebSocket protocol 。

现很多网站为了实现即时通讯，所用的技术都是轮询(polling)。轮询是在特定的的时间间隔（如每1秒），由浏览器对服务器发出HTTP request，然后由服务器返回最新的数据给客户端的浏览器。这种传统的HTTP request 的模式带来很明显的缺点 – 浏览器需要不断的向服务器发出请求，然而HTTP request 的header是非常长的，里面包含的有用数据可能只是一个很小的值，这样会占用很多的带宽。

而比较新的技术去做轮询的效果是Comet – 用了AJAX。但这种技术虽然可达到全双工通信，但依然需要发出请求。

在 WebSocket API，浏览器和服务器只需要做一个握手的动作，然后，浏览器和服务器之间就形成了一条快速通道。两者之间就直接可以数据互相传送。在此WebSocket 协议中，为我们实现即时服务带来了两大好处：

1. Header

互相沟通的Header是很小的-大概只有 2 Bytes

2. Server Push

服务器的推送，服务器不再被动的接收到浏览器的request之后才返回数据，而是在有新数据时就主动推送给浏览器。

一、项目简介

WebSocket是HTML5一种新的协议，它实现了浏览器与服务器全双工通信，这里就将使用WebSocket来开发网页聊天室，前端框架会使用AmazeUI，后台使用Java，编辑器使用UMEditor。

二、涉及知识点

网页前端（HTML+CSS+JS）和Java

三、软件环境 Tomcat 7 JDK 7 Eclipse JavaEE 现代浏览器

四、效果截图

效果1

3. 编写后台代码

新建一个com.shiyanlou.chat的包，在包中创建一个名为ChatServer的类，从JavaEE 7开始就统一了WebSocket的API，因此无论是什么服务器，用Java写的代码都是一样的，代码如下：

?

041424344454647484950 package com.shiyanlou.chat;import java.text.SimpleDateFormat;import java.util.Date;import javax.websocket.OnClose;import javax.websocket.OnError;import javax.websocket.OnMessage;import javax.websocket.OnOpen;import javax.websocket.Session;import javax.websocket.server.ServerEndpoint;import net.sf.json.JSONObject;/*** 聊天服务器类* @author shiyanlou**/@ServerEndpoint("/websocket")public class ChatServer {private static final SimpleDateFormat DATE_FORMAT = new SimpleDateFormat("yyyy-MM-dd HH:mm"); // 日期格式化@OnOpenpublic void open(Session session) {// 添加初始化操作}/*** 接受客户端的消息，并把消息发送给所有连接的会话* @param message 客户端发来的消息* @param session 客户端的会话*/@OnMessagepublic void getMessage(String message, Session session) {// 把客户端的消息解析为JSON对象JSONObject jsonObject = JSONObject.fromObject(message);// 在消息中添加发送日期jsonObject.put("date", DATE_FORMAT.format(new Date()));// 把消息发送给所有连接的会话for (Session openSession : session.getOpenSessions()) {// 添加本条消息是否为当前会话本身发的标志jsonObject.put("isSelf", openSession.equals(session));// 发送JSON格式的消息openSession.getAsyncRemote().sendText(jsonObject.toString());}}@OnClosepublic void close() {// 添加关闭会话时的操作}@OnErrorpublic void error(Throwable t) {// 添加处理错误的操作}}

4. 前后台交互

后台写完了，前台要用WebSocket连接后台，需要新建一个WebSocket对象，然后就可以和服务器端进行交互，从浏览器发送消息给服务器端，同时要验证输入框的内容是否为空，然后接受服务端发送的消息，把它们动态地添加到聊天内容框中，在

?

04142434445464748495051525354 var um = UM.getEditor('myEditor');$('#nickname')[0].focus();// 新建WebSocket对象，最后的/websocket对应服务器端的@ServerEndpoint("/websocket")var socket = new WebSocket('ws://${pageContext.request.getServerName()}:${pageContext.request.getServerPort()}${pageContext.request.contextPath}/websocket');// 处理服务器端发送的数据socket.onmessage = function(event) {addMessage(event.data);};// 点击Send按钮时的操作$('#send').on('click', function() {var nickname = $('#nickname').val();if (!um.hasContents()) { // 判断消息输入框是否为空// 消息输入框获取焦点um.focus();// 添加抖动效果$('.ei-container').addClass('am-animation-shake');setTimeout("$('.ei-container').removeClass('am-animation-shake')", 1000);} else if (nickname == '') { // 判断昵称框是否为空//昵称框获取焦点$('#nickname')[0].focus();// 添加抖动效果$('#message-input-nickname').addClass('am-animation-shake');setTimeout("$('#message-input-nickname').removeClass('am-animation-shake')", 1000);} else {// 发送消息socket.send(JSON.stringify({content : um.getContent(),nickname : nickname}));// 清空消息输入框um.setContent('');// 消息输入框获取焦点um.focus();}});// 把消息添加到聊天内容中function addMessage(message) {message = JSON.parse(message);var messageItem = '<li class="am-comment '+ (message.isSelf ? 'am-comment-flip' : 'am-comment')+ '">'+ '<a href="javascript:void(0)" ><img src="assets/images/'+ (message.isSelf ? 'self.png' : 'others.jpg')+ '" alt="" width="48" height="48"/></a>'+ '<div><header><div>'+ '<a href="javascript:void(0)">'+ message.nickname + '</a> <time>' + message.date+ '</time></div></header>'+ '<div>' + message.content+ '</div></div></li>';$(messageItem).appendTo('#message-list');// 把滚动条滚动到底部$(".chat-content-container").scrollTop($(".chat-content-container")[0].scrollHeight);}

到这步，简单的网页聊天室就完成了，你可以多开几个窗口或在局域网中邀请小伙伴们来一起测试。

六、小结

本次项目课使用WebSocket实现了简单的网页聊天室，其实WebSocket不仅可以应用于浏览器，也可以应用于桌面客户端。

⑦ java消息推送websocket怎么实现

⑧ 如何用java实现websocket

1. 服务器端实现(Tomcat)

2. 客户端实现(Java-WebSocket)

3. 客户端实现(Javascript原生API)