将gRPC Pro buf消息转换为json运行很长时间
我们正在尝试将gRPC protobuf消息最终转换为json格式的对象，以便在python中进行处理。从服务器以序列化格式发送的数据约为35MB，约有15K条记录。但当我们将protobuf消息转换为字符串（使用MessageToString）时，大约是135 MB，而将protobuf消息转换为JSON字符串（使用MessageToJson）时，大约是140MB。但每次转换所需的时间约为5分钟。如果我们在客户端花这么多时间转换数据，它不会增加任何价值。
我们遗漏的任何想法、建议或警告都将有所帮助。谢谢。
共有1个答案
修复了此问题，方法是仅选择反序列化数据时所需的字段，而不是反序列化从服务器返回的所有数据。
-
我正在尝试将单个输入消息转换为多个消息。我有一个带有以下签名的方法： 类类似于： 对于中的每个，我想创建一个的实例。我如何做到这一点并处理
-
我正在尝试将excel文件转换为XSSFWorkbook，我有大约7000行和大约145列。将excel文件转换为第2行的XSSFWorkbook大约需要15分钟，代码如下：- 我不想向XFFSWorkbook添加7000行，只想在第2行转换时向XFFSWorkbook添加30行？ 如果没有，如何减少将excel转换为XSSFWorkbook所需的时间？
-
我有一个Python进程（或者更确切地说，在一个使用者组中并行运行的一组进程），它根据来自某个主题的Kafka消息输入来处理数据。通常每条消息的处理都很快，但有时，取决于消息的内容，可能需要很长时间（几分钟）。在这种情况下，Kafka broker断开客户端与组的连接，并启动重新平衡。我可以将设置为一个非常大的值，但它可能会超过10分钟，这意味着如果客户机死亡，集群在10分钟内无法正确地重新平衡。
-
我在使用spring-jms模块转换来自RabbitMQ的消息时遇到了一些问题。以前，我使用Rest APIendpoint发送消息，该endpoint将消息发送到RabbitMQ队列，并使用@JMSListener方法处理它。 在内部，这种行为添加了一个字段来确定Java类型，由Spring库管理。但是，现在我想避免Rest API调用，因为它不是必需的，而且我可以直接将消息发送到RabbitM
-
我想填充Javapojo类与mqtt消息有效载荷在一个Springmvc应用程序。我的代码是： MQTT MessagePayload是{“name”：“abc”，“age”：32}，但当它在变量MessagePayload中转换为字符串时，它显示为类似{name:abc，age:32}。你看，去掉所有的双引号。当转到try块时，会抛出一个错误com。fasterxml。杰克逊。果心JsonPar
-
问题内容： 我在大学的最后一个项目中正在使用Google云消息传递。一切正常，但是我在使用GCM时遇到了一些麻烦。通常，消息要么立即发送，要么延迟很大。 我已经读过了，在这种情况下我真的不认为它适用： GCM通常会在邮件发送后立即发送。但是，这并不总是可能的。例如，设备可能已关闭，处于脱机状态或不可用。在其他情况下，发件人本身可能会使用delay_while_idle标志要求在设备变为活动状态之前