一 应用
打开一个页面，将向服务器发送一段字符串，并通过onmessage事件监听器来接受服务器返回的消息。
二 代码
客户端代码
<!DOCTYPE html>
<html>
<head>
<meta name="author" content="Yeeku.H.Lee(CrazyIt.org)" />
<meta http-equiv="Content-Type" content="text/html; charset=UTF-8" />
<title> 使用WebSocket通信 </title>
</head>
<body>
<script type="text/javascript">
// 创建Web Socket对象
var webSocket = new WebSocket("ws://127.0.0.1:30000");
// 当WebSocket建立网络连接时激发该函数
webSocket.onopen= function()
{
alert("已打开连接");
// 发送消息
webSocket.send("haha web socket");
}
// 为onmessage事件绑定监听器，接收消息
webSocket.onmessage= function(event)
{
// 接收消息
alert("收到的消息是：" + event.data);
}
</script>
</body>
</html>
服务器代码
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
import java.nio.charset.Charset;
import java.security.MessageDigest;
import java.util.regex.Matcher;
import java.util.regex.Pattern;
import sun.misc.BASE64Encoder;
public class SimpleServer
{
public SimpleServer()throws Exception
{
// 创建ServerSocket，准备接受客户端连接
ServerSocket ss = new ServerSocket(30000);
// 接收到客户端连接
Socket socket = ss.accept();
// 得到Socket对应的输入流
InputStream in = socket.getInputStream();
// 得到Socket对应的输出流
OutputStream out = socket.getOutputStream();
byte[] buff = new byte[1024];
int count = -1;
String req = "";
// 读取数据，此时建立与WebSocket的"握手"。
count = in.read(buff);
// 将读取的数据转化为字符串
req = new String(buff , 0 , count);
System.out.println("握手请求：" + req);
// 获取WebSocket的key
String secKey = getSecWebSocketKey(req);
System.out.println("secKey = " + secKey);
String response = "HTTP/1.1 101 Switching Protocols\r\nUpgrade: "
+ "websocket\r\nConnection: Upgrade\r\nSec-WebSocket-Accept: "
+ getSecWebSocketAccept(secKey) + "\r\n\r\n";
System.out.println("secAccept = " + getSecWebSocketAccept(secKey));
out.write(response.getBytes());
// 再次读取WebSocket发送过来的数据
count = in.read(buff);
System.out.println("接收的字节数：" + count);
/*
因为WebSocket发送过来的数据遵循了一定的协议格式，
其中第3个～第6个字节是数据掩码。
从第7个字节开始才是真正的有效数据。
因此程序使用第3个～第6个字节对后面的数据进行了处理
*/
for (int i = 0 ; i < count - 6 ; i++ )
{
buff[i + 6] = (byte) (buff[i % 4 + 2] ^ buff[i + 6]);
}
// 显示读取得到的数据
System.out.println("接收的内容：" + new String(buff
, 6 , count - 6 , "UTF-8"));
// 发送数据时，第一个字节必须与读到的第一个字节相同
byte[] pushHead = new byte[2];
pushHead[0] = buff[0];
String pushMsg = "收到，收到！欢迎加入WebSocket世界！";
// 发送数据时，第二个字节记录发送数据的长度
pushHead[1] = (byte) pushMsg.getBytes("UTF-8").length;
// 发送前两个字节
out.write(pushHead);
// 发送有效数据
out.write(pushMsg.getBytes("UTF-8"));
// 关闭Socket
socket.close();
// 关闭ServerSocket
ss.close();
}
// 获取WebSocket请求的SecKey
private String getSecWebSocketKey(String req)
{
//构建正则表达式，获取Sec-WebSocket-Key: 后面的内容
Pattern p = Pattern.compile("^(Sec-WebSocket-Key:).+",
Pattern.CASE_INSENSITIVE | Pattern.MULTILINE);
Matcher m = p.matcher(req);
if (m.find())
{
// 提取Sec-WebSocket-Key
String foundstring = m.group();
return foundstring.split(":")[1].trim();
}
else
{
return null;
}
}
// 根据WebSocket请求的SecKey计算SecAccept
private String getSecWebSocketAccept(String key)
throws Exception
{
String guid = "258EAFA5-E914-47DA-95CA-C5AB0DC85B11";
key += guid;
MessageDigest md = MessageDigest.getInstance("SHA-1");
md.update(key.getBytes("ISO-8859-1") , 0 , key.length());
byte[] sha1Hash = md.digest();
BASE64Encoder encoder = new BASE64Encoder();
return encoder.encode(sha1Hash);
}
public static void main(String[] args)
throws Exception
{
new SimpleServer();
}
}
三 运行结果
相关推荐
在Python中，我们可以使用多种库来实现WebSocket通信，如`ws4py`、`autobahn`、`websockets`等。这里我们主要讨论`websockets`库，这是一个简洁且功能强大的库，特别适合于初学者和专业开发者。 首先，要创建一个...
总结，WebSocketSharp为Unity提供了强大且易用的WebSocket支持，无论是在客户端还是服务端，都能轻松实现WebSocket通信。通过理解并掌握WebSocketSharp的使用，开发者能够构建出高效、可靠的实时网络应用。在实际...
2. **数据帧格式**：WebSocket通信的数据由多个帧组成，每个帧包含头部和数据两部分。头部定义了数据的类型（文本、二进制等）、是否为最后一个帧、掩码等信息。 3. **心跳机制**：为了检测连接是否正常，WebSocket...
在Android上实现WebSocket通信，通常需要以下步骤： 1. **选择WebSocket库**： - Android平台上常见的WebSocket库有Socket.IO、OkHttp-WebSocket-Client、Autobahn等。这里我们以OkHttp-WebSocket-Client为例，...
WebSocket协议作为一种在单个TCP连接上进行全双工通信的技术，使得客户端和服务器之间能够进行低延迟、高效率的数据交换，非常适合于实时推送通知、在线聊天、游戏实时更新等场景。使用C# WinForm结合WebSocket...
总之，`C# VS MVC 下WebSocket简单应用`涵盖了使用C#和ASP.NET MVC在IIS服务器上构建WebSocket聊天应用的基本步骤，适合初学者学习和实践。通过这个项目，你可以深入了解WebSocket的使用，以及如何在C#环境中构建...
下面将详细介绍Spring WebSocket通信应用实例，包括其工作原理、配置、心跳监测以及如何构建一个简单的WebSocket应用。 一、WebSocket概述 WebSocket协议是HTTP协议的一个补充，旨在提供低延迟、高效率的全双工通信...
在易语言中，我们可以通过使用支持库来实现WebSocket通信。在这个案例中，"易语言支持库服务器组件"可能是用于处理WebSocket连接和数据交换的工具，它简化了程序员与WebSocket服务器交互的过程。 源码中提到“没有...
下面通过一个简单的案例来演示 WebSocket 的使用方法： 1. **WebSocket 服务器端代码：** - 可以使用 Node.js 的 `ws` 模块轻松搭建 WebSocket 服务器。 - 服务器监听客户端的连接请求，并处理客户端发送过来的...
总的来说，"简单的WebSocket实现"教程旨在帮助开发者理解如何在Java环境下使用Eclipse和Tomcat搭建WebSocket服务器，以及如何编写客户端代码进行通信。这个过程中涉及的主要知识点包括WebSocket协议、JSR 356规范、...
综上所述，WebSocket通信工具的开发涉及客户端和服务器端的实现，连接管理和错误处理，以及安全性和性能优化等多个层面，是一个综合性的技术实践。通过有效的WebSocket工具开发，我们可以构建出更加实时、高效的Web...
实现WebSocket通信的第一步是设置服务器端。在C#中，我们需要使用SuperWebSocket库创建一个WebSocket服务，监听特定的端口，并处理来自客户端的连接请求。服务端代码会包含设置监听端口、启动服务以及处理接收到的...
WebSocket是Web应用中的一种...服务端通过Java API处理WebSocket连接和消息交互，客户端使用HTML5 WebSocket API与服务器进行实时通信。这样的架构为实现实时交互应用提供了基础，如在线聊天室、实时股票信息显示等。
- 在浏览器环境中如何使用JavaScript实现WebSocket通信。 - 如何在服务器端处理WebSocket连接，以及广播消息给所有连接的客户端。 此外，对于一个简单的聊天室应用，你还需要关注用户体验，比如输入框的设计、消息...
2. **帧结构**：WebSocket通信基于帧，每个数据包都由帧组成，包含操作码、掩码标识、掩码键和有效载荷。这使得WebSocket能传输文本和二进制数据。 3. **事件驱动编程**：WebSocket API设计为事件驱动，如`onopen`,...
在服务器端，实现WebSocket通信通常需要借助特定的库或框架。例如，在Node.js环境中，可以使用`ws`库来创建WebSocket服务器。服务器端代码会监听连接事件，当新的客户端连接时，可以设置监听`message`事件来接收...
在"使用WebSocket简单实现群发消息和指定用户发送消息"的实践中，我们通常会有一个WebSocket服务端（WebSocketSev）处理来自客户端的连接和消息。首先，我们需要创建一个WebSocket服务器，监听特定的端口，并等待...
c# winform快速建websocket服务器源码 wpf快速搭建websocket服务 c#简单建立websocket服务 websocket快速搭建 ...本文将探讨WebSocket通信技术的优势，并阐述为何选择C#作为服务端开发语言的几大理由。
在传统的HTTP协议中，每次请求-响应交互都需要重新建立连接，而WebSocket则在连接建立后，允许双向数据流，使得客户端与服务器能够进行频繁的数据交换，非常适合用于聊天应用、在线游戏、股票交易等需要实时更新的...