Cscmobi.NetCore.WebSockets 1.0.2

Code Server

Tạo WebSocket Server

public class WebSocketServer : BaseServer<GameClient>
{
        private static readonly ILog log = LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType);

        public WebSocketServer(IServiceProvider serviceProvider) : base(serviceProvider)
        {
        }

        public override void OnClientConnected(GameClient client)
        {
            log.Info($"client: {client.SessionId} connected");
        }

        public override void OnClientDisconnected(GameClient client)
        {
            log.Info($"client: {client.SessionId} disconnected");
        }

        protected override GameClient GetNewClient(string sessionId, WebSocket socket, IServiceProvider serviceProvider)
        {
            return new GameClient(sessionId, socket, serviceProvider);
        }
}
public class GameClient : BaseClient
{
        public GameClient(string sessionId, WebSocket sock, IServiceProvider serviceProvider) : base(2048, sessionId, sock, serviceProvider)
        {
        }
        protected override void HandleMessage(byte[] buffer, int length)
        {
            base.HandleMessage(buffer, length);
        }
}

Tạo server websocket trong net core

• Trong class Program.s

public static void Main(string[] args)
{
    var builder = WebApplication.CreateBuilder(args);

    // Add services to the container.

    //... something code

    //Khởi tạo websocket server
    builder.Services.AddWebSocketServices("/ws", provider => new WebSocketServer(provider));
           
    var app = builder.Build();
    //...something code
    //Sử dụng middleware để accept client
    app.UseWebSocketMiddleWare<WebSocketServer>();
    //Run app
    app.Run();
}

Tạo handle xử lý message

• Ví dụ class LoginHandle.cs

[PacketHandler(0, "Login Handle")]
public class LoginHandle : IPacketHandler
{
    public int HandlePacket(IBaseClient client, PacketIn packet)
    {
		byte[] data = packet.ReadBytes();
		string message = Encoding.UTF8.GetString(data);
		PacketIn pkg = new PacketIn(1);
		pkg.Write(Encoding.UTF8.GetBytes("Server chao ban"));
		pkg.WriteHeader();
		client.SendAsync(pkg).Wait();
		Console.WriteLine(message);
		return 0;
	}
}