40 lines
1.2 KiB
C#
40 lines
1.2 KiB
C#
using System;
|
|
using System.Threading;
|
|
using System.Threading.Tasks;
|
|
using Websocket.Client;
|
|
|
|
namespace WSDemo
|
|
{
|
|
class Program
|
|
{
|
|
static void Main(string[] args)
|
|
{
|
|
var exitEvent = new ManualResetEvent(false);
|
|
var url = new Uri("wss://web.cqjgjyw.cn/websocket");
|
|
|
|
using (var client = new WebsocketClient(url))
|
|
{
|
|
client.ReconnectTimeout = TimeSpan.FromSeconds(30);
|
|
client.ReconnectionHappened.Subscribe(info =>
|
|
Console.WriteLine($"Reconnection happened, type: {info.Type}"));
|
|
|
|
client.MessageReceived.Subscribe(msg => Console.WriteLine($"Message received: {msg}"));
|
|
client.StartOrFail();
|
|
|
|
Task.Run(() => client.Send("{code:10000,nick:\"张三\",\"room\":\"push_1500\"}"));
|
|
Task.Run(() =>
|
|
{
|
|
while (true)
|
|
{
|
|
client.Send($"{{\"code\":10086,\"mess\":\"{Guid.NewGuid()}\",\"room\":\"push_1500\"}}");
|
|
client.Send("{code:10016}");
|
|
Thread.Sleep(5000);
|
|
}
|
|
});
|
|
|
|
exitEvent.WaitOne();
|
|
}
|
|
}
|
|
}
|
|
}
|