2

我在 C# (NetMQ) 中使用以下代码发送大对象：

var client = new DealerSocket("<connection String>");
var serializedData = new string('*', 500000);
var message = new List<byte[]>();
message.Add(Encoding.UTF8.GetBytes("BulkSend"));
message.Add(Encoding.UTF8.GetBytes(serializedData));
client.TrySendMultipartBytes(TimeSpan.FromMilliseconds(3000), message);

如果在高流量（例如每秒 10MB 消息）中使用此代码，它将占用 90% 的 CPU 使用率。经过一番研究，我尝试了以下两个代码。首先，我删除了第一帧（“批量发送”）：

var client = new DealerSocket("<connection String>");
var serializedData = new string('*', 500000);
var message = new List<byte[]>();
message.Add(Encoding.UTF8.GetBytes(serializedData));
client.TrySendMultipartBytes(TimeSpan.FromMilliseconds(3000), message);

令人惊讶的是，性能得到了改善。其次，我重新排列了两个框架。我的意思是将大框架移到第一个。如下所示：

var client = new DealerSocket("<connection String>");
var serializedData = new string('*', 500000);
var message = new List<byte[]>();
// change the order of two following codes
message.Add(Encoding.UTF8.GetBytes(serializedData));
message.Add(Encoding.UTF8.GetBytes("BulkSend"));

client.TrySendMultipartBytes(TimeSpan.FromMilliseconds(3000), message);

再次令人惊讶的是，性能得到了改善！

有什么问题？我怎样才能提高性能？在 netmq 上使用 zproto 怎么样？是否有任何适当的文件？

4

2 回答 2

1

正如我发现的那样，发送多部分消息存在问题。你可以看到这个链接http://hintjens.com/blog:84。并且可能将您的消息编码为一条消息然后发送！

于 2016-07-20T07:09:18.710 回答
0

高 CPU/低性能可能是因为 GC 和内存分配。我尝试使用我的框架发送相同大小的消息，该框架使用 NetMQ，服务器和客户端在同一台机器上工作。如果客户端在向服务器发送另一条消息之前等待响应，我达到了 60K msg/sec。然而，如果客户端并行发送数百条消息，CPU 也很高，吞吐量为每秒数十条消息。在某个时间点，我什至遇到了 OutOfMemoryException。如果您发布完整的代码，那就太好了。

UPD：对不起，我测错了。并行发送 100 条消息或仅发送一条消息时，性能仅为120 msg/sec

于 2016-07-19T11:21:00.537 回答