패킷 모아보내기

 

using ServerCore;
using System;
using System.Collections.Generic;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace Server
{
    class GameRoom : IJobQueue
    {
        List<ClientSession> _sessions = new List<ClientSession>();
        JobQueue _jobQueue = new JobQueue();
        List<ArraySegment<byte>> _pendingList = new List<ArraySegment<byte>>();

        public void Push(Action job)
        {
            _jobQueue.Push(job);
        }

        public void Flush()
        {
            foreach (ClientSession s in _sessions)
                s.Send(_pendingList);

            Console.WriteLine($"Flushed : {_pendingList.Count} items");
            _pendingList.Clear();
        }

        public void Broadcast(ClientSession session, string chat)
        {
            S_Chat packet = new S_Chat();
            packet.playerId = session.SessionId;
            packet.chat = $"{chat} I am {packet.playerId}";
            ArraySegment<byte> segment = packet.Write();

            _pendingList.Add(segment);

        }

        public void Enter(ClientSession session)
        {
            _sessions.Add(session);
            session.Room = this;
        }

        public void Leave(ClientSession session)
        {
            _sessions.Remove(session);
        }

    }
}

 

using System.Net;
using System.Net.Sockets;
using System.Text;
using ServerCore;

namespace Server
{
    

    class Program
    {

        static Listener _listener = new Listener();
        public static GameRoom Room = new GameRoom();

        static void Main(string[] args)
        {
            // DNS
            string host = Dns.GetHostName();
            IPHostEntry ipHost = Dns.GetHostEntry(host);
            IPAddress iPAddr = ipHost.AddressList[0];
            IPEndPoint endPoint = new IPEndPoint(iPAddr, 7777);


            _listener.init(endPoint, () => { return SessionManager.instance.Generate(); });
            Console.WriteLine("Listening.... ");

            while (true)
            {
                Room.Push(() => Room.Flush());
                Thread.Sleep(250);
            }


        }
    }
}

 

 

 

session class

public void Send(List<ArraySegment<byte>> sendBuffList)
{
    // 예외처리 안해주면 completed에서 disconnect 날 수 있음
    // args가 전송 받은 내용이 없을테니
    if (sendBuffList.Count == 0)
        return;

    lock (_obj)
    {
        foreach(ArraySegment<byte> sendBuff in sendBuffList)
            _sendQueue.Enqueue(sendBuff);

        if (_pendingList.Count == 0)
            RegisterSend();
    }
}

 

 

recvBuffer, sendBuffer 크기 늘려줌