TNonblockingServerTransport 未使用 Thrift C# 库实现

Question

使用 Apache Thrift [https://github.com/apache/thrift] 在 C# 中创建非阻塞服务器时，无法识别以下类/类型：

TNonblockingServerTransport
TNonblockingServer

我想从我的 win10 笔记本电脑发送命令来控制在高性能服务器 (ubuntu) 上执行的耗时计算。这就是我来到 Apache Thrift 的原因。我找到了官方的 C# 版本教程 [https://github.com/apache/thrift/tree/master/tutorial/csharp]，它运行良好。本教程使用所谓的阻塞模式 (TSimpleServer)。但在我的情况下，耗时的计算过程应该是可中断的。因此，我必须使用非阻塞服务器。

逻辑很简单。对于服务器，我使用了一个私有标志 forceStop。如果客户端调用 Stop()，forceStop 将设置为 true，计算循环将中断。

        // #Server#
        // Server Set-Up
        private void SetUp()
        {
         try
            {
                CalculatorHandler handler = new CalculatorHandler();
                Calculator.Processor processor = new 
                Calculator.Processor(handler);
                var serverTransport = new TServerSocket(9090);
                TServer server = new TSimpleServer(processor, serverTransport);

                // Use this for a multithreaded server
                // server = new TThreadPoolServer(processor, serverTransport);

                Console.WriteLine("Starting the server...");
                server.Serve();
            }
            catch (Exception x)
            {
                Console.WriteLine(x.StackTrace);
            }
        }

        private bool forceStop;
        public int TimeConsumingOperation(int n1, int n2)
        {
            Console.WriteLine("add({0},{1})", n1, n2);
            for (int i = 0; i < 10; i++)
            {
                //calculating
                Thread.Sleep(500);

                if (forceStop)
                {
                    Quit();
                }
            }
            return n1 + n2;
        }

        public void Stop()
        {
            forceStop = true;
        }

// Client

// Button#1 Click callback
private void Button_Start_Click()
{
    client.TimeConsumingOperation(0,0);
}

// Button#2 Click callback
private void Button_Stop_Click()
{
    client.Stop();
}
//

我在 java [https://chamibuddhika.wordpress.com/2011/10/02/apache-thrift-quickstart-tutorial/].我已经尽力将非阻塞服务器的java代码转换为相应的C#代码，但我发现C#中似乎没有TNonblockingServerTransport。有人可以帮我解决这个问题吗？

// Java Code
public class NonblockingServer {

    private void start() {
        try {
            TNonblockingServerTransport serverTransport = new TNonblockingServerSocket(7911);
            ArithmeticService.Processor processor = new ArithmeticService.Processor(new ArithmeticServiceImpl());

            TServer server = new TNonblockingServer(new TNonblockingServer.Args(serverTransport).
                    processor(processor));
            System.out.println("Starting server on port 7911 ...");
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }

    public static void main(String[] args) {
        NonblockingServer srv = new NonblockingServer();
        srv.start();
    }
}

Answer 1

这个问题实际上有两个答案。

可能的实现

首先，您的设置有缺陷。

    // #Server#
    // Server Set-Up

    private bool forceStop;

    public void Stop()
    {
        forceStop = true;
    }

假设我们有两个客户端，都开始一个新的计算。现在一位客户想要中止。会发生什么？

解决方案是以这样一种方式构建它，其中计算是一个单独的业务逻辑对象，在 TimeConsumingOperation() 实例化并通过某种方式提供给客户端，通常是通过返回某种 ID。

当客户端现在想要中止时，它调用Stop(calcualtionID)。服务器端逻辑现在将调用路由到实现并触发任何可能的中止机制，C# 可能是CancellationToken。

计算完成后，需要第三次调用从服务器端查询最终结果。请注意，我们仍然使用TSimpleServer，它之所以有效是因为我们通过 API 设计避免了阻塞调用。

非阻塞服务器

是的，C# 还没有实现。由于 Thrift 是开源的，这可能只是意味着到目前为止没有人遇到该用例并希望花时间在实现上。这并不是说这样的用例可能不存在。

存在的是

• 线程和线程池服务器
• Task.Run(() => { your code })

这可能有助于解决您的用例。此外，当与 ASP.NET 一起使用时，不需要非阻塞服务器，因为运行时已经为多个连接提供了足够的支持。

底线

有一些方法可以解决您遇到的限制。另一个替代方案是 become a contributor，通过将现有（例如 Java）非阻塞实现之一移植到 NetStd（首选，因为 C# 和 NetCore 将在下一个版本中成熟为“已弃用”状态，最终都将被 NetStd 取代)