Cscmobi.NetCore.TcpSocket 1.0.3

Server Program

1. Tạo config cho log4net

File log4net.config

<log4net>
  <root>
    <level value="ALL" />
    <appender-ref ref="console" />
  </root>

  
  <appender name="console" type="log4net.Appender.ManagedColoredConsoleAppender">
    <mapping>
      <level value="INFO" />
      <forecolor value="Green" />
    </mapping>
    <mapping>
      <level value="WARN" />
      <forecolor value="Yellow" />
    </mapping>
    <mapping>
      <level value="ERROR" />
      <forecolor value="Red" />
    </mapping>
    <mapping>
      <level value="DEBUG" />
      <forecolor value="Blue" />
    </mapping>
    <layout type="log4net.Layout.PatternLayout">
      <conversionpattern value="%date [%thread] %-5level - %message%newline" />
    </layout>
  </appender>
</log4net>

2. Code cho Server

    public class Program
    {
        static async Task Main(string[] args)
        {
            // Load configuration
            var logRepository = LogManager.GetRepository(Assembly.GetEntryAssembly());
            XmlConfigurator.Configure(logRepository, new FileInfo("log4net.config"));
            GameServer server = new GameServer(IPAddress.Parse("127.0.0.1"), 8888);
            server.Start();
        }
    }

    /// <summary>
    /// MessagePack data.
    /// </summary>
    [MessagePackObject(true)]
    public class Person
    {
        public string name { get; set; }
        public int age { get; set; }
    }
    /// <summary>
    /// Tạo classs GameClient để handle Packet
    /// </summary>
    public class GameClient : BaseClient
    {
        public static readonly ILog log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
        public GameClient(byte[] readBuffer, byte[] sendBuffer) : base(readBuffer, sendBuffer)
        {
            AsyncPostSend = true;
        }
        public override void OnRecvPacket(GSPacketIn pkg)
        {
            //pkg.ReadHeader();
            byte[] data = pkg.ReadBytes();
            var person = MessagePackSerializer.Deserialize<Person>(data);
            log.Info($"person: name:{person?.name} - age: {person?.age}");
        }
    }
    /// <summary>
    /// Class GameServer kế thừa từ Base
    /// </summary>
    public class GameServer : BaseServer<GameClient>
    {
        public static readonly ILog log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);

        public GameServer(IPAddress ip, int port) : base(ip, port)
        {
        }

        public override GameClient GetNewClient()
        {
            return new GameClient(new byte[2048], new byte[2048]);
        }

        public override void OnClientConnected(GameClient client)
        {
            log.InfoFormat("Welcome {0}", client.TcpEndpoint);
            GSPacketIn pkg = new GSPacketIn(2);
            pkg.WriteString("Welcome Client");
            client.SendTCP(pkg);
        }

        public override void OnClientDisconnected(GameClient client)
        {
            log.InfoFormat("Goodbye {0}", client.TcpEndpoint);
        }
    }

3. Code cho client

    public class Program
    {
        private static readonly ILog log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
        static void Main(string[] args)
        {
            // Load configuration
            var logRepository = LogManager.GetRepository(Assembly.GetEntryAssembly());
            XmlConfigurator.Configure(logRepository, new FileInfo("log4net.config"));
            GameClient client = new GameClient("127.0.0.1", 8888);
            client.Connect();
            byte[] buffer = MessagePackSerializer.Serialize(new Person() { name = "tuyen", age = 33 });
            GSPacketIn pkg = new GSPacketIn(0);
            pkg.Write(buffer);
            client.SendTCP(pkg);
            Console.ReadKey();
        }


    }
    public class GameClient : BaseConnector
    {
        private static readonly ILog log = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);
        public GameClient(string ip, int port) : base(ip, port, true, new byte[2048], new byte[2048])
        {
        }
        public override void OnRecvPacket(GSPacketIn pkg)
        {
            string message = pkg.ReadString();
            log.Info($"Server Send: {message}");
        }
    }
    [MessagePackObject(true)]
    public class Person
    {
        public string name { get; set; }
        public int age { get; set; }
    }

4. Chạy server trước, sau đó đến Client và nhận kết quả

INFO  - person: name:tuyen - age: 33