1

我想nanomsg用作总线系统。因此，我尝试编写性能测试代码并使用两台 PC 对其进行测试。

起初我写了一个服务器，它连接到另一个服务器：

#include <nanomsg/nn.h>
#include <nanomsg/bus.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>

int main(int argc, char *argv[]) {
  if (argc == 2) {
    int socket = nn_socket (AF_SP_RAW, NN_BUS);
    assert(nn_bind (socket, "tcp://*:27384") != -1);
    assert(nn_connect (socket, argv[1]) != -1);

    assert(nn_device(socket, -1) != -1);

    nn_close(socket);
  }
}

就我而言，我将这些命令运行为：

在第一台电脑上：
./server tcp://192.168.1.11:27384

在第二台电脑上：
./server tcp://192.168.1.241:27384

它们是连接的，为了证明这一点，我nanocat在本地使用并将其连接到服务器：

在第一台电脑上：
nanocat --bus --connect tcp://127.0.0.1:27384 --data foo --interval 1 --ascii

在第二台电脑上：
nanocat --bus --connect tcp://127.0.0.1:27384 --data bar --interval 1 --ascii

在第一台 PC 上，我每秒收到一个“bar”，在第二台 PC 上，我每秒收到一个“foo”。

所以我现在写了接收器。

#include <nanomsg/nn.h>
#include <nanomsg/bus.h>
#include <string.h>
#include <stdio.h>
#include <assert.h>

int main(int argc, char *argv[]) {
  int socket = nn_socket (AF_SP, NN_BUS);
  assert(nn_connect (socket, "tcp://127.0.0.1:27384") != -1);

  sleep(1);

  unsigned char buffer[4096];

  while(1) {
    int n = nn_recv(socket, buffer, 4096, 0);

    if (n > 0) {
      nn_send(socket, buffer, strlen(buffer), 0);
    }
  }

  nn_close(socket);
}

它接收一条消息并将其发回。

然后我写了发件人：

#include <nanomsg/nn.h>
#include <nanomsg/bus.h>
#include <stdio.h>
#include <unistd.h>
#include <time.h>
#include <string.h>

#define NANO_PER_SEC 1000000000.0

int main(int argc, char *argv[]) {
  int socket = nn_socket (AF_SP, NN_BUS);
  nn_connect (socket, "tcp://127.0.0.1:27384");

  sleep(1);

  unsigned char buffer[4096];

  int i = 0;
  for (i = 0; i < 1024; i++) {
    buffer[i] = 'a';
  }
  buffer[i] = '\0';

  struct timespec start, end;
  double start_sec, end_sec, elapsed_sec;
  double average;

  double m[4096];

  for (i = 0; i < 4096; i++) {
    clock_gettime(CLOCK_REALTIME, &start);

    int ns = nn_send(socket, buffer, strlen(buffer), 0);
    int nr = nn_recv(socket, buffer, 4096, 0);

    clock_gettime(CLOCK_REALTIME, &end);
    start_sec = start.tv_sec + start.tv_nsec/NANO_PER_SEC;
    end_sec = end.tv_sec + end.tv_nsec/NANO_PER_SEC;
    m[i] = end_sec - start_sec;
  }

  elapsed_sec = 0.0;
  for (i = 0; i < 4096; i++) {
    elapsed_sec = elapsed_sec + m[i];
  }
  average = (elapsed_sec / 4096.0) * 1000000.0;
  printf("Average: %.3f micros\nWhole: %.12f seconds\n", average, elapsed_sec);

  nn_close(socket);
}

发送方向接收方发送 4096 次 1kbyte 并测量时间，所以我得到了整个时间和平均时间。

起初我只在本地一台 PC 上测试它，在三个打开的​​ bash 终端中。

第一终端：
./server tcp://192.168.1.11:27384
第二终端：
./receiver

第三终端：
./sender

所以，我从“发件人”程序中得到了这个输出：

Average: 60.386 micros
Whole: 0.247341632843 seconds

然后我尝试运行这个：

在第一台电脑上：
./server tcp://192.168.1.11:27384
./receiver

在第二台电脑上：
./server tcp://192.168.1.241:27384
./sender

但它卡住了，运行“接收器”的第一台 PC 没有收到来自运行“发送方”的第二台 PC 的任何消息。我不明白有什么问题，因为nanocat它可以正常工作。

有人能帮帮我吗？

4

0 回答 0