notify/Notify/Ipc/PipeServer.cs

using System;
using System.IO;
using System.IO.Pipes;
using System.Text;
using System.Text.Json;
using System.Threading.Tasks;
using Notify.Serialization;

namespace Notify.Ipc;

/// <summary>
/// Host 侧命名管道监听：每个连接读取一条 PipeMessage 并回调
/// </summary>
public sealed class PipeServer
{
    private readonly Action<PipeMessage> _onMessage;

    public PipeServer(Action<PipeMessage> onMessage) => _onMessage = onMessage;

    public void Start() => Task.Run(RunLoopAsync);

    private async Task RunLoopAsync()
    {
        while (true)
        {
            try
            {
                using var server = new NamedPipeServerStream(
                    IpcConstants.PipeName,
                    PipeDirection.In,
                    NamedPipeServerStream.MaxAllowedServerInstances,
                    PipeTransmissionMode.Byte,
                    PipeOptions.Asynchronous);

                await server.WaitForConnectionAsync().ConfigureAwait(false);

                using var ms = new MemoryStream();
                await server.CopyToAsync(ms).ConfigureAwait(false);

                var json = Encoding.UTF8.GetString(ms.ToArray());
                if (string.IsNullOrWhiteSpace(json))
                {
                    continue;
                }

                var msg = JsonSerializer.Deserialize(json, AppJsonContext.Default.PipeMessage);
                if (msg is not null)
                {
                    _onMessage(msg);
                }
            }
            catch
            {
                // 单个连接出错不影响后续监听
            }
        }
    }
}