揭秘：如何让 Windows 服务和浏览器无缝交互？

windows

2024-03-05 19:38:31

通过 WebSocket 或 HTTP 长轮询实现 Windows 服务和浏览器交互

问题

设想你有一项 Windows 服务，你希望它能够与用户的浏览器进行交互。然而，Windows 服务本身没有登录功能，并且用户可能拥有多台计算机。因此，你需要一种方法来识别用户正在使用的计算机，并在其上执行服务操作。

WebSocket 解决方案

WebSocket 是一种全双工通信协议，可用于在客户端和服务器之间建立持久的双向通信通道。我们可以使用 WebSocket 在网站和 Windows 服务之间创建通信通道。

Windows 服务端： 使用 WebSocket 库创建一个 WebSocket 服务器，监听特定的端口。
浏览器端： 使用 WebSocket 库创建一个 WebSocket 客户端，连接到服务端的 WebSocket 服务器。
通信过程： 当用户在网站上触发事件时，浏览器端通过 WebSocket 客户端向服务端发送请求，其中包含用户 ID 等信息。服务端收到请求后，根据需要执行相应的操作，并通过 WebSocket 服务器向浏览器端发送响应。

HTTP 长轮询解决方案

HTTP 长轮询是一种技术，允许客户端持续向服务器轮询新数据，直到服务器有新数据可用。我们可以使用 HTTP 长轮询在网站和 Windows 服务之间创建通信通道。

Windows 服务端： 创建一个 HTTP API，用于接收来自网站的请求并返回用户 ID 等信息。
浏览器端： 使用 JavaScript 定期向服务端的 HTTP API 发送 HTTP GET 请求。
通信过程： 如果服务端有新的用户 ID，则 HTTP 响应将包含该 ID。浏览器端收到响应后，根据需要执行相应的操作。

示例代码

Windows 服务端 (WebSocket)

using SuperWebSocket;
using System.Threading;

namespace WebSocketService
{
    public class Program
    {
        private static WebSocketServer _server;

        public static void Main(string[] args)
        {
            _server = new WebSocketServer();
            _server.Setup(9000);
            _server.Start();

            Thread thread = new Thread(PollNewData);
            thread.Start();

            Console.ReadLine();
        }

        private static void PollNewData()
        {
            while (true)
            {
                // 从数据库获取新数据
                var newData = GetNewData();

                // 向所有已连接的客户端广播新数据
                _server.Broadcast("newData:" + newData);

                Thread.Sleep(1000);
            }
        }
    }
}

Windows 服务端 (HTTP 长轮询)

using System;
using System.Net;
using System.Net.Http;
using System.Threading;

namespace HttpLongPollingService
{
    public class Program
    {
        private static HttpListener _listener;

        public static void Main(string[] args)
        {
            _listener = new HttpListener();
            _listener.Prefixes.Add("http://localhost:9000/");
            _listener.Start();

            Thread thread = new Thread(PollNewData);
            thread.Start();

            Console.ReadLine();
        }

        private static void PollNewData()
        {
            while (true)
            {
                // 从数据库获取新数据
                var newData = GetNewData();

                // 监听来自网站的 HTTP GET 请求
                HttpListenerContext context = _listener.GetContext();
                HttpListenerResponse response = context.Response;

                // 向客户端发送 HTTP 响应
                response.StatusCode = 200;
                response.OutputStream.Write(System.Text.Encoding.UTF8.GetBytes("newData:" + newData));

                Thread.Sleep(1000);
            }
        }
    }
}

网站端 (WebSocket)

using SocketIOClient;
using System;

namespace Website
{
    public class Program
    {
        private static SocketIO _socket;

        public static void Main(string[] args)
        {
            _socket = new SocketIO("localhost:9000");
            _socket.Connect();

            // 当用户点击按钮时，向服务端发送 ID
            document.getElementById("button").addEventListener("click", function() {
                _socket.emit("ID", "your_id");
            });

            // 监听来自服务端的响应
            _socket.On("message", (data) => {
                console.log(data);
            });
        }
    }
}

网站端 (HTTP 长轮询)

using System;
using System.Net.Http;
using System.Threading;

namespace Website
{
    public class Program
    {
        public static void Main(string[] args)
        {
            // 定期向 Windows 服务发送 HTTP GET 请求
            while (true)
            {
                using (var client = new HttpClient())
                {
                    var response = client.GetAsync("http://localhost:9000/api/GetID").Result;
                    if (response.IsSuccessStatusCode)
                    {
                        var id = response.Content.ReadAsStringAsync().Result;
                        console.log(id);
                    }
                }

                Thread.Sleep(1000);
            }
        }
    }
}