class Program:WebSocketServer
{
static void Main(string[] args)
{
TcpUtils.Setup("beetle")
Program server = new Program()
server.Open(8088)
Console.WriteLine("websocket start@8088")
System.Threading.Thread.Sleep(-1)
}
protected override void OnConnected(object sender, ChannelEventArgs e)
{
base.OnConnected(sender, e)
}
protected override void OnDisposed(object sender, ChannelDisposedEventArgs e)
{
base.OnDisposed(sender, e)
}
protected override void OnError(object sender, ChannelErrorEventArgs e)
{
base.OnError(sender, e)
}
protected override void OnWebSocketReceive(TcpChannel channel, DataPackage e)
{
Console.WriteLine("MessageType:{0}", e.Type)
Console.WriteLine("RequestPath:{0}", e.RequestPath)
if (e.Type == PackageType.text)
{
Console.WriteLine(e.ToString())
DataPackage dp = new DataPackage()
dp.Type = PackageType.text
dp.Data.Encoding("hello " + e.ToString(), Encoding.UTF8)
channel.Send(dp)
}
}
}
以上就是一个完整的websocket服务,代码非常简单WebSocketServer重写OnWebSocketReceive即可,在事件中根据需要处理对应的DataPackage即可,对于DataPackage的结构和类型实现参考下载代码.
Html代码
<html>
<meta charset="utf-8" />
<title>WebSocket Test</title>
<script language="javascript" type="text/javascript">
var wsUri = "ws://127.0.0.1:8088/"
var output
function init() {
output = document.getElementById("output")
testWebSocket()
}
function testWebSocket() {
websocket = new WebSocket(wsUri)
websocket.onopen = function (evt) { onOpen(evt) }
websocket.onclose = function (evt) { onClose(evt) }
websocket.onmessage = function (evt) { onMessage(evt) }
websocket.onerror = function (evt) { onError(evt) }
} function onOpen(evt) {
writeToScreen("CONNECTED")
}
function onClose(evt) { writeToScreen("DISCONNECTED")}
function onMessage(evt) { document.getElementById('result').value = evt.data}
function onError(evt) { writeToScreen('<span style="color: red">ERROR:</span>' + evt.data)}
function doSend(message) { websocket.send(message)}
function writeToScreen(message) {
var pre = document.createElement("p")pre.style.wordWrap = "break-word"pre.innerHTML = messageoutput.insertBefore(pre)
}
function OnConnect() {
wsUri = document.getElementById("url").value
init()
}
</script>
<body>
<fieldset>
<legend>WebSocket hello wold</legend>
<p><span>Server url:</span><input id="url" type="text" value="ws://127.0.0.1:8088/"/><input type="button" value="Connected" onclick="OnConnect()" /></p>
<p><span>Enter you name:</span><input id="youname" type="text" value="test"/><input type="button" value="Submit" onclick="doSend(document.getElementById('youname').value)" /></p>
<p><span>Result:</span><input id="result" type="text" value=""/></p>
</fieldset>
<div id="output">
</div>
</body>
</html>
springboot 整合 websocket的使用，Demo实例在码云里；
1.启动项目报错@ServerEndpoint 注册失败，java.lang.IllegalStateException: Failed to register @ServerEndpoint class: class com.*$$EnhancerBySpringCGLIB$$b83c4359，参考了下： https://www.jianshu.com/p/bc15f83cf374 ，解决办法是：将此类放移至非aop扫描包之下
2. WebSocket错误：java.lang.IllegalStateException: The WebSocket session [1] has been closed and no method (apart from close()) may be called on a closed session ，出现这个问题的原因是：在建立连接时保存的对象id，在断开连接时移除失败，所以对应services中的onOpen()方法存储的id 以及 onClose()方法中移除的id ，即可。
3.本地开发的时候，需要手写WebsocketConfiguration类，交由spring管理 ServerEndpointExporter 类，但是当打包war包然后运行在tomcat等中间件时，此类将影响项目启动websocket，所以打包时需注意这个文件
HTTP协议的生命周期是通过Request和Response来界定的，而Response是被动的（服务端不能主动与客户端通信），收到 一次请求才会返回一次响应。而当服务端需要主动和客户端进行通信，或者需要建立全双工通信（保持在一个连接中）时，HTTP就力不从心了。
在Websocket出现之前，实现全双工通信的方式主要是ajax轮询和long poll，这样是非常消耗性能的。
WebSocket是HTML5 新增加的特性之一，目前主流浏览器大都提供了对其的支持。其特点是可以在客户端和服务端之间建立全双工通信，一些特殊场景，例如实时通信、在线游戏、多人协作等，WebSocket都可以作为解决方案。
Spring自4.0版本后增加了WebSocket支持，本例就使用Spring WebSocket构建一个简单实时聊天的应用。
Spring WebSocket提供了一个WebSocketHandler接口，这个接口提供了WebSocket连接建立后生命周期的处理方法。
WebSocketSession不同于HttpSession，每次断开连接（正常断开或发生异常断开）都会重新起一个WebSocketSession。
这个抽象类提供了一系列对WebSocketSession及传输消息的处理方法：
spring WebSocket提供了四种WebSocketMessage的实现：TextMessage（文本类消息）、BinaryMessage（二进制消息）、PingMessage、PongMessage（后两者用于心跳检测，在一端收到了Ping消息的时候，该端点必须发送Pong消息给对方，以检测该连接是否存在和有效）。
HandshakeInterceptor接口是WebSocket连接握手过程的拦截器，通过实现该接口可以对握手过程进行管理。值得注意的是，beforeHandshake中的attributes与WebSocketSession中通过getAttributes()返回的Map是同一个Map，我们可以在其中放入一些用户的特定信息。
通过实现WebSocketConfigurer接口，可以注册相应的WebSocket处理器、路径、允许域、SockJs支持。
url为指定的WebSocket注册路径，当协议为http时，使用ws://，当协议为https，使用wss://。
onmessage的event对象：
可以看出，应使用event.data获取服务端发送的消息。
有的浏览器不支持WebSocket，使用SockJs可以模拟WebSocket。
以下使用WebSocket构建一个实时聊天应用。
1.客户端与服务端通信只使用TextMessage（文本类消息），客户端只能发送聊天文本，服务端可以单播和广播消息，包括聊天文本、上线、下线、掉线、用户列表信息、认证信息和服务器时间。
2.以HttpSession来唯一区别用户，而不是WebSocketSession。
3.核心思路是当新的WebSocketSession建立时，将其加入一个集合，当该session失效时（close、error）将其从集合中删除，当服务端需要单播或广播消息时，以这个集合为根据。
新建Spring Boot项目，添加必要依赖。
（其实在WebSocket中已经没有了请求、响应之分，但习惯上将客户端发送的消息称为请求，服务端发送的消息称为响应）
从chrome的WS控制台，我们可以看到发送的信息
通过setAllowedOrigins(String... origins)方法可以限制访问，查看WebSocket Request Headers的Origin属性：
这种限制与限制跨域是类似的，不同的是端口号不在其限制范围内。可以通过setAllowedOrigins("*")的方式设置允许所有域。
使用WebSocket构建实时聊天
苦逼的IE同志说不出话来，只算到IE11可能不支持WebSocket，没想到他其实是不支持contenteditable="plaintext-only"（后来又发现火狐也不支持）。
WebSocket是一个长连接，需要心跳检测机制来判断服务端与客户端之间建立的WebSocket连接是否存在和有效。当服务端断开连接时，客户端会立马断开连接，并调用websocket.close，而当客户端出现中断网络连接的情况，服务端不会立马作出反应（Spring WebSocket不会），而是过一段时间（推测是几分钟）后才将这个断掉的WebSocketSession踢出。
使用WebSocket构建实时聊天
欢迎分享，转载请注明来源：内存溢出
微信扫一扫
支付宝扫一扫
评论列表（0条）