71 lines
2.3 KiB
C#
71 lines
2.3 KiB
C#
using System;
|
|
using System.Threading;
|
|
|
|
namespace JoyD.Windows.CS.WebSocket
|
|
{
|
|
/// <summary>
|
|
/// WebSocket测试类
|
|
/// </summary>
|
|
public class WebSocketTest
|
|
{
|
|
/// <summary>
|
|
/// 测试WebSocket客户端
|
|
/// </summary>
|
|
public static void TestClient()
|
|
{
|
|
Console.WriteLine("开始测试WebSocket客户端...");
|
|
|
|
var config = new WebSocketConfig
|
|
{
|
|
WsUrl = "ws://localhost:8086/ws",
|
|
DebugMode = true
|
|
};
|
|
|
|
var client = new WebSocketClient(config);
|
|
|
|
// 订阅事件
|
|
client.Connected += (sender, e) => Console.WriteLine("连接成功");
|
|
client.Disconnected += (sender, e) => Console.WriteLine("连接断开");
|
|
client.Error += (sender, e) => Console.WriteLine("错误: " + e.Message);
|
|
client.Message += (sender, e) => Console.WriteLine("收到消息: " + e.Data);
|
|
|
|
// 连接服务器
|
|
client.Connect();
|
|
|
|
// 发送测试消息
|
|
Thread.Sleep(1000);
|
|
client.Send("test", new { Message = "Hello, WebSocket!" });
|
|
|
|
Console.WriteLine("按任意键退出...");
|
|
Console.ReadKey();
|
|
|
|
// 断开连接
|
|
client.Disconnect();
|
|
}
|
|
|
|
/// <summary>
|
|
/// 测试WebSocket服务器
|
|
/// </summary>
|
|
public static void TestServer()
|
|
{
|
|
Console.WriteLine("开始测试WebSocket服务器...");
|
|
|
|
var server = new WebSocketServer();
|
|
|
|
// 订阅事件
|
|
server.ClientConnected += (sender, e) => Console.WriteLine("客户端连接: " + e.ClientId);
|
|
server.ClientDisconnected += (sender, e) => Console.WriteLine("客户端断开: " + e.ClientId);
|
|
server.MessageReceived += (sender, e) => Console.WriteLine("收到消息: " + e.Data);
|
|
|
|
// 启动服务器
|
|
server.Start(8086);
|
|
Console.WriteLine("服务器已启动，端口: 8086");
|
|
|
|
Console.WriteLine("按任意键停止服务器...");
|
|
Console.ReadKey();
|
|
|
|
// 停止服务器
|
|
server.Stop();
|
|
}
|
|
}
|
|
} |