public
void ProcessRequest(Stream input, Stream output)
{
//TTransport transport = new TStreamTransport(input,output);
TTransport inTransport =
new TStreamTransport(input, output);
//在out加入缓存机制
TBufferedTransport outTransport =
new TBufferedTransport((TStreamTransport)inTransport);
//TTransport transport = new TStreamTransport(input, output);
TProtocol inputProtocol =
null ;
TProtocol outputProtocol =
null ;
try
{
inputProtocol = inputProtocolFactory.GetProtocol(inTransport);
outputProtocol = outputProtocolFactory.GetProtocol(outTransport);
while
(processor.Process(inputProtocol, outputProtocol)) { }
}
catch
(TTransportException)
{
// Client died, just move on
}
catch
(TApplicationException tx)
{
Console.Error.Write(tx);
}
catch
(Exception x)
{
Console.Error.Write(x);
}
inTransport.Close();
outTransport.Close();
}
|