HP-Socket与SuperSocket的区别

// HP-Socket需要引入其提供的DLL库
using HP.SockLib;

// TCP服务器
public class HPSocketTcpServer
{
    private TCPServer server;

    public void StartServer()
    {
        server = new TCPServer();
        server.OnAccept += OnAccept;
        server.OnReceive += OnReceive;
        server.Start(8888); // 监听8888端口
    }

    private void OnAccept(object sender, AcceptEventArgs e)
    {
        Console.WriteLine($"Client connected: {e.ConnectionID}");
    }

    private void OnReceive(object sender, ReceiveEventArgs e)
    {
        Console.WriteLine($"Received data: {Encoding.UTF8.GetString(e.Buffer)}");
        e.Connection.Send(e.Buffer, e.Length); // 回显数据
    }
}

// TCP客户端
public class HPSocketTcpClient
{
    private TCPClient client;

    public void ConnectToServer()
    {
        client = new TCPClient();
        client.OnConnect += OnConnect;
        client.OnReceive += OnReceive;
        client.Connect("127.0.0.1", 8888);
    }

    private void OnConnect(object sender, ConnectEventArgs e)
    {
        Console.WriteLine("Connected to server");
        client.Send(Encoding.UTF8.GetBytes("Hello, HP-Socket!"));
    }

    private void OnReceive(object sender, ReceiveEventArgs e)
    {
        Console.WriteLine($"Server response: {Encoding.UTF8.GetString(e.Buffer)}");
    }
}

// SuperSocket需要通过NuGet安装SuperSocket包
using SuperSocket;
using SuperSocket.Server;
using SuperSocket.ProtoBase;
using System.Net;
using System.Text;

// 自定义协议处理器
public class MyTextReceiveFilter : IReceiveFilter<string>
{
    public IReceiveFilter<string> NextReceiveFilter { get; set; }

    public string ParseBuffer(IAppSession session, byte[] buffer, int offset, int length, out int rest)
    {
        var message = Encoding.UTF8.GetString(buffer, offset, length);
        rest = 0;
        return message;
    }

    public bool CheckComplete(IAppSession session, string data)
    {
        return true;
    }
}

// TCP服务器
public class MyTcpServer : AppServer<MyTcpSession, string>
{
    protected override void OnSessionConnected(MyTcpSession session)
    {
        Console.WriteLine($"Client connected: {session.RemoteEndPoint}");
    }

    protected override void OnNewRequest(MyTcpSession session, string requestInfo)
    {
        Console.WriteLine($"Received data: {requestInfo}");
        session.Send(Encoding.UTF8.GetBytes("Hello from SuperSocket!"));
    }
}

public class MyTcpSession : AppSession<MyTcpSession, string>
{
}

public class Program
{
    public static void Main()
    {
        var server = new MyTcpServer();
        server.Setup(new ServerOptions
        {
            Port = 8888,
            ReceiveFilterFactory = new DefaultReceiveFilterFactory<MyTextReceiveFilter>()
        });

        server.Start();
        Console.WriteLine("Server started on port 8888");
        Console.ReadLine();
    }
}