HPSocket.Net

Install-Package HPSocket.Net

// Create HttpEasyServer instance
using(IHttpEasyServer httpServer = new HttpEasyServer())
{
    // ... other settings

    // Binding OnEasyMessageData event
    httpServer.OnEasyMessageData += (sender, id, data) => 
    {
        // The data parameter is a complete packet each time
        // ... Process data

        return HttpParseResult.Ok;
    };
}

// Create HttpEasyAgent instance
using(IHttpEasyAgent httpAgent = new HttpEasyAgent())
{
    // ... other settings

    // Binding OnEasyMessageData event
    httpAgent.OnEasyMessageData += (sender, id, data) => 
    {
        // The data parameter is a complete packet each time
        // ... Process data

        return HttpParseResult.Ok;
    };
}

// Create HttpEasyClient instance
using(IHttpEasyClient httpClient = new HttpEasyClient())
{
    // ... other settings

    // Binding OnEasyMessageData event
    httpClient.OnEasyMessageData += (sender, data) => 
    {
        // The data parameter is a complete packet each time
        // ... Process data

        return HttpParseResult.Ok;
    };
}

using (ITcpServer<byte[]> server = new TcpServer<byte[]>
    {
        // Specify the data receiving adapter
        DataReceiveAdapter = new BinaryDataReceiveAdapter(),
    })
{
    // No need to bind OnReceive event
    // The data of the request body event parsed here is the data returned by BinaryDataReceiveAdapter.ParseRequestBody ()
    // The type of data is the byte[] specified when ITcpServer <byte[]> is instantiated
    server.OnParseRequestBody += (sender, id, data) =>
    {
        Console.WriteLine($"OnParseRequestBody({id}) -> data length: {data.Length}");

        return HandleResult.Ok;
    };
}

{ 0x03, 0x00, 0x00, 0x00, 0x61, 0x62, 0x63 }

using System;
using System.Text;
using HPSocket.Adapter;
using Models;
using Newtonsoft.Json;

namespace TcpServerTestEchoAdapter.DataReceiveAdapter
{
    /// <summary>
    /// Fixed header data receiving adapter
    /// </summary>
    public class PacketDataReceiveAdapter : FixedHeaderDataReceiveAdapter<Packet>
    {
        /// <summary>
        /// Call the parent class constructor, specifying the length of the fixed header and the maximum packet length
        /// </summary>
        public PacketDataReceiveAdapter()
            : base(
                headerSize: 4,        // Specify a 4-byte header here
                maxPacketSize: 0x1000 // The maximum packet length specified here cannot exceed 4K
                )
        {

        }

        /// <summary>
        /// Get request body length
        /// <remarks>Subclasses must override this method</remarks>
        /// </summary>
        /// <param name="header">Header. The length of the header is the length specified in the constructor. This method is called when a header of the specified length is received.</param>
        /// <returns>Returns the body length</returns>
        protected override int GetBodySize(byte[] header)
        {
            // Adapt the byte order according to the business scenario, and the byte order at both ends must be consistent.

            // If the current environment is not little-endian
            if (!BitConverter.IsLittleEndian)
            {
                // Convert to little-endian byte order
                Array.Reverse(header);
            }

            // Because the header is 4 bytes, it is directly converted to int and returned
            return BitConverter.ToInt32(header, 0);
        }

        /// <summary>
        /// Parsing the request body
        /// <remarks>Subclasses must override this method</remarks>
        /// </summary>
        /// <param name="header">header</param>
        /// <param name="data">body data</param>
        /// <returns></returns>
        protected override Packet ParseRequestBody(byte[] header, byte[] data)
        {
            // Deserialize data into object
            // Here is the object of the Packet class
            return JsonConvert.DeserializeObject<Packet>(Encoding.UTF8.GetString(data));
        }
    }
}

using HPSocket.Adapter;

namespace TcpServerTestEchoAdapter.DataReceiveAdapter
{
    /// <summary>
    /// Fixed-length packet data receiving adapter
    /// </summary>
    public class BinaryDataReceiveAdapter : FixedSizeDataReceiveAdapter<byte[]>
    {
        /// <summary>
        /// Call the parent class constructor and specify the fixed-length package length
        /// </summary>
        public BinaryDataReceiveAdapter()
            : base(
                packetSize: 1024 // Fixed length packet length 1K bytes
            )
        {
        }

        /// <summary>
        /// Parsing the request body
        /// <remarks>Subclasses must override this method</remarks>
        /// </summary>
        /// <param name="data">Fixed-length data handled by the parent class</param>
        /// <returns></returns>
        protected override byte[] ParseRequestBody(byte[] data)
        {
            // Because inherited from FixedSizeDataReceiveAdapter <byte[]>, it is returned directly here, if it is other types, please complete the conversion and then return
            return data;
        }
    }
}

hello world 1\r\n
hello world 2\r\n
hello world 3\r\n

using System.Text;
using HPSocket.Adapter;

namespace TcpServerTestEchoAdapter.DataReceiveAdapter
{
    /// <summary>
    /// Terminator data receiving adapter
    /// </summary>
    public class TextDataReceiveAdapter : TerminatorDataReceiveAdapter<string>
    {
        /// <summary>
        /// Call parent constructor, specify terminator
        /// </summary>
        public TextDataReceiveAdapter()
            : base(
                terminator: Encoding.UTF8.GetBytes("\r\n") // Specify the terminator as \r\n, which means that each piece of data ends with \r\n. Pay attention to the encoding problem, and keep the two sides consistent.
                )
        {
        }

        /// <summary>
        /// Parsing the request body
        /// <remarks>Subclasses must override this method</remarks>
        /// </summary>
        /// <param name="data">Data that has been processed by the parent class, without terminator.</param>
        /// <returns></returns>
        protected override string ParseRequestBody(byte[] data)
        {
            // Converted to the request object, pay attention to the character encoding, both sides must be consistent.
            return Encoding.UTF8.GetString(data);
        }
    }
}

##hello world!## // begin with ##, end with ##

##hello world!|| // begin with ##, end with ||

**hello world!|##| // begin with **, end with |##|

using System.Text;
using HPSocket.Adapter;

namespace TcpServerTestEchoAdapter.DataReceiveAdapter
{
    /// <summary>
    /// Interval data receiving adapter
    /// </summary>
    public class HeadTailDataReceiveAdapter : BetweenAndDataReceiveAdapter<string>
    {
        /// <summary>
        /// Call the parent class constructor, specifying the start and end characteristic characters of the section
        /// </summary>
        public HeadTailDataReceiveAdapter() 
            : base( // For example, the data format is "#* 123456 *#", which starts with #* and ends with *#, and the middle 123456 part is the real data
                start : Encoding.UTF8.GetBytes("#*"),  // Section start identifier, starting with #* here, pay attention to encoding issues, and be consistent at both sides
                end : Encoding.UTF8.GetBytes("*#")  // Section end identifier, ends with *# here, pay attention to encoding issues, and be consistent at both sides
                )
        {
        }

        /// <summary>
        /// Parsing the request body
        /// <remarks>Subclasses must override this method</remarks>
        /// </summary>
        /// <param name="data">Data that has not been processed by the parent class identifier character</param>
        /// <returns></returns>
        protected override string ParseRequestBody(byte[] data)
        {
            // Converted to the request object, pay attention to the character encoding, both sides must be consistent.
            return Encoding.UTF8.GetString(data);
        }
    }
}