req-rep

wangzhengquan

2020-10-13 1577a5d11a9341e506331df86870997d49fd441b

req-rep

 src/socket/net_mod_socket.c

@@ -98,7 +98,7 @@
  for(int i =0; i< size; i++) {
    free(arr[i].content);
  }

  free(arr);
}

// ssize_t recv(void *buf, size_t len) {

 test_net_socket/net_mod_req_rep.c

@@ -22,6 +22,7 @@
    };

  while (fgets(send_buf, MAXLINE, stdin) != NULL) {
      // 收到消息的节点即使没有对应的信息， 也要回复一个表示无的消息,否则会一直等待
    client.sendandrecv( node_arr, 4, send_buf, strlen(send_buf), &recv_arr, &recv_arr_size);
    for(i=0; i<recv_arr_size; i++) {
        printf("host:%s, port: %d, key:%d, content: %s\n", 
@@ -31,7 +32,7 @@
            recv_arr[i].content
        );
    }

//使用完后，不要忘记释放掉
    NetModSocket::free_recv_msg_arr(recv_arr, recv_arr_size);
  }
}