TCP_JSON#07

InvsRequestHandler.cs

public class InvsRequestHandler : AbstractBaseRequestHandler, IRTRequestHandler
{
    protected override void run()
    {
        try
        {
            while (true)
            {
                NetworkStream ns = clientSocket.GetStream();
                StringBuilder response = new StringBuilder();
                var buffer = new byte[clientSocket.ReceiveBufferSize+10];
                while (ns.DataAvailable)
                {
                    int bytes = ns.Read(buffer, 0, clientSocket.ReceiveBufferSize);
                    response.Append(Encoding.Unicode.GetString(buffer, 0, bytes));
                }
                if (String.IsNullOrEmpty(response.ToString()))
                {
                    continue;
                }

                ParamDTO deserialized = JSONHelper.deserialize<ParamDTO>(response.ToString());

                //Your Business Logic         
                IList<BusinnesLogicDTO> resultls= ProcessSomeLogic(param);
                //...
                
                //Serialize Object and Send Result Back to Client
                Byte[] mb = JSONHelper.serializeObject<IList<BusinnesLogicDT>(resultls);    
                ns.Write(mb, 0, mb.Length);
                ns.Flush();
            }
        } 
        catch (Exception wex)
        {
            clientSocket.Close();
            logger.Error(wex.Message);
        }
    }
}