1

我正在尝试将多个客户端连接到服务器，所有连接的客户端都从服务器获取相同的数据。像客户端这样的东西可以订阅服务并从服务器获取相同的数据。

我尝试将多个客户端连接到服务器并发送递增数字流。它工作正常，但是当新客户端进入时，它应该从接收相同数据的旧客户端开始。

服务器流式传输消息：

 def str(self, request, context):

        digit = 0
        m = 'Turn'
        print('Message Type:, %s!' % request.type)
        if request.type == 'Streaming':
            while True:
                direction = m
                    #digit = random.randint(0,100)
                digit+=1
                yield text.Response(message='Move, %s!' % direction,dir=a)

我想将此消息多播到多个连接的客户端

4

0 回答 0