SunlightAggregationTerminal/Class/HttpServer.cs

using System;
using System.Collections.Generic;
using System.Net.Sockets;
using System.Text;
using System.Text.Json;
using TouchSocket.Core;
using TouchSocket.Http;
using TouchSocket.Http.WebSockets;
using TouchSocket.Sockets;
using static SunlightAggregationTerminal.Class.TcpServer;

namespace SunlightAggregationTerminal.Class
{
    public class HttpServer
    {
        public static TouchSocket.Http.HttpClient httpclient = new TouchSocket.Http.HttpClient();

        public static async void Configuration(string ip, string Name, string Password, string Terminal)
        {
            ServerIP = ip;
            ServerName = Name;
            ServerPassword = Password;
            ServerTerminal = Terminal;

            await HttpClient("127.0.0.1:7791");
        }

        public static async Task HttpClient(string url)
        {
            var config = new TouchSocketConfig();
            #region Http设置远程服务器地址
            config.SetRemoteIPHost("http://" + url);
            #endregion

            #region Http客户端获取断线通知
            config.ConfigurePlugins(a =>
            {
                a.AddTcpClosedPlugin(async (c, e) =>
                {
                    // 专门处理超时或主动取消的情况
                    MainThread.BeginInvokeOnMainThread(() =>
                    {
                        Application.Current!.Windows[0].Page!.DisplayAlertAsync("", "客户端断开连接", "是");
                    });
                    await e.InvokeNext();
                });
            }); config.ConfigurePlugins(a =>
            {
                a.AddTcpConnectedPlugin(async (c, e) =>
                {
                    HttpTransmit("{\"Command\":\"Log\"}");
                    await e.InvokeNext();
                });
            });
            config.ConfigurePlugins(a =>
            {
                a.UseReconnection<TouchSocket.Http.HttpClient>(options =>
                {
                    options.PollingInterval = TimeSpan.FromSeconds(3);
                });
            });
            #endregion

            //配置config
            await httpclient.SetupAsync(config);
            //连接
            await httpclient.ConnectAsync();
        }

        /***发送信息处理***/
        public static async void HttpTransmit(string Dat)
        {
            var dat = new Person()
            {
                User = ServerName,
                Password = ServerPassword,
                IP = GetLocalIpSimple(),
                Terminal = ServerTerminal,
                Dat = Dat
            };

            var t = JsonSerializer.Serialize(dat);
            var p = httpclient.RemoteIPHost.Host;

            var request = new HttpRequest();
            request.SetContent(new StringHttpContent(t, Encoding.UTF8, "application/scjson"))
                .InitHeaders()
                .SetUrl("/api/user-report")
                .SetHost(p)
                .AsPost();

            // 创建一个超时操作，10秒后取消
            using var cts = new CancellationTokenSource(1000 * 15);
            try
            {
                using (var responseResult = await httpclient.RequestAsync(request, cts.Token))
                {
                    var response = responseResult.Response;
                    // GetBodyAsync 同样需要响应取消信号，如果这里超过剩余时间也会抛出异常
                    var result = await response.GetBodyAsync();
                    DataReceived.Received(result);
                }
            }
            catch (OperationCanceledException)
            {
                // 专门处理超时或主动取消的情况
                MainThread.BeginInvokeOnMainThread(() =>
                {
                    Application.Current!.Windows[0].Page!.DisplayAlertAsync("网络错误", "网络请求超时，请检查网络或服务器状态。", "是");
                });
            }
            catch (Exception ex)
            {
                MainThread.BeginInvokeOnMainThread(() =>
                {
                    Application.Current!.Windows[0].Page!.DisplayAlertAsync("网络错误", ex.Message.ToString(), "是");
                });
            }
        }

        
    

    }
}