WebSocketServer MSDN示例
WebSocketServer MSDN示例
提问于 2013-11-18 10:02:49
我写了一个简单的WebSocketServer，这是我在MSDN网站上发现的。但不起作用。你能解释一下我应该如何运行这个简单的项目吗?因为我启动了它，但什么也没发生。
服务器
namespace WebSocketServer
{
class Program
{
static void Main(string[] args)
{
var task1 = Run();
// Console.ReadLine();
}
public static async Task Run()
{
HttpListener s = new HttpListener();
s.Prefixes.Add("http://localhost:8000/ws");
s.Start();
var hc = await s.GetContextAsync();
if (!hc.Request.IsWebSocketRequest)
{
hc.Response.StatusCode = 400;
hc.Response.Close();
return;
}
var wsc = await hc.AcceptWebSocketAsync(null);
var ws = wsc.WebSocket;
for (int i = 0; i != 10; ++i)
{
// await Task.Delay(20);
var time = DateTime.Now.ToLongTimeString();
var buffer = Encoding.UTF8.GetBytes(time);
var segment = new ArraySegment<byte>(buffer);
await ws.SendAsync(segment, System.Net.WebSockets.WebSocketMessageType.Text, true, CancellationToken.None);
}
await ws.CloseAsync(WebSocketCloseStatus.NormalClosure, "Done", CancellationToken.None);
}
}}
客户端
namespace WebSocketClient
{
class Program
{
static void Main(string[] args)
{
var clientTask1 = Client();
Console.ReadLine();
}
static async Task Client()
{
ClientWebSocket ws = new ClientWebSocket();
var uri = new Uri("ws://localhost:8000/ws/");
await ws.ConnectAsync(uri, CancellationToken.None);
var buffer = new byte[1024];
while (true)
{
var segment = new ArraySegment<byte>(buffer);
var result = await ws.ReceiveAsync(segment, CancellationToken.None);
if (result.MessageType == WebSocketMessageType.Close)
{
await ws.CloseAsync(WebSocketCloseStatus.InvalidMessageType, "I don't do binary", CancellationToken.None);
return;
}
int count = result.Count;
while (!result.EndOfMessage)
{
if (count >= buffer.Length)
{
await ws.CloseAsync(WebSocketCloseStatus.InvalidPayloadData, "That's too long", CancellationToken.None);
return;
}
segment = new ArraySegment<byte>(buffer, count, buffer.Length - count);
result = await ws.ReceiveAsync(segment, CancellationToken.None);
count += result.Count;
}
var message = Encoding.UTF8.GetString(buffer, 0, count);
Console.WriteLine(">" + message);
}
}
}
}我需要创建一个简单的网站，它将从WebSocketServer获取一些数据(例如时间)并显示在这个页面上。我写了一些代码，但什么也没发生
<html>
<body>
<script type ="text/javascript">
var ws = new WebSocket("ws://localhost:8000/ws/");
ws.onmessage = function (args)
{
var time = args.data;
};
</script>
</body>
</html>回答 1
Stack Overflow用户
发布于 2013-11-18 10:09:43
在服务器上，Run是一个async方法；一旦到达结果尚未完成的第一个await，它就会返回给调用方。这意味着您的服务器将退出Main，在没有任何其他主线程(非工作线程)的情况下，服务器将终止。Console.ReadLine在那里是有原因的。放回去：
static void Main(string[] args)
{
var task1 = Run();
Console.WriteLine("Press return to exit the server");
Console.ReadLine();
}页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接：
https://stackoverflow.com/questions/20044960
复制相关文章
相似问题
腾讯云开发者
