nanomsg REQ/REP

nanomsg是一个轻量级的消息传递库，支持多种通信模式。其中，REQ/REP是一种基于请求和回复的通信模式。

在REQ/REP模式中，客户端发送请求消息，服务端接收并处理请求，然后发送回复消息给客户端。客户端等待接收回复消息，一旦接收到回复消息，请求完成。

这种通信模式适用于简单的请求和回复场景，如客户端向服务端请求某些数据或执行某些操作，并等待服务端的回复。

相关问题

在centos环境下，cpu为x86_64，使用nanomsg的req/rep模式，写一个服务器和客户端通信的demo，客户端发送内容“123”，服务器回复“abc”，用纯C语言写。

以下是一个简单的基于nanomsg的REQ/REP模式的服务器和客户端通信的demo，代码中已注释说明：

服务器端代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/reqrep.h>

#define SERVER_ADDRESS "tcp://127.0.0.1:5555" // 服务器地址

int main()
{
    int sock = nn_socket(AF_SP, NN_REP); // 创建一个REP类型的socket
    if (sock < 0) {
        fprintf(stderr, "nn_socket error: %s\n", nn_strerror(nn_errno()));
        return -1;
    }

    if (nn_bind(sock, SERVER_ADDRESS) < 0) { // 绑定服务器地址
        fprintf(stderr, "nn_bind error: %s\n", nn_strerror(nn_errno()));
        nn_close(sock);
        return -1;
    }

    printf("server started, waiting for client...\n");

    while (1) {
        char *buf = NULL;
        int bytes = nn_recv(sock, &buf, NN_MSG, 0); // 接收客户端请求消息
        if (bytes < 0) {
            fprintf(stderr, "nn_recv error: %s\n", nn_strerror(nn_errno()));
            nn_close(sock);
            return -1;
        }

        printf("server received: %s\n", buf);

        if (strcmp(buf, "123") == 0) { // 判断客户端请求消息是否为"123"
            char *response = "abc";
            int response_len = strlen(response) + 1;
            int bytes = nn_send(sock, response, response_len, 0); // 发送回复消息
            if (bytes < 0) {
                fprintf(stderr, "nn_send error: %s\n", nn_strerror(nn_errno()));
                nn_close(sock);
                return -1;
            }
        } else {
            printf("invalid request\n");
        }

        nn_freemsg(buf); // 释放接收到的消息内存
    }

    nn_close(sock); // 关闭socket

    return 0;
}

客户端代码：

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <nanomsg/nn.h>
#include <nanomsg/reqrep.h>

#define SERVER_ADDRESS "tcp://127.0.0.1:5555" // 服务器地址

int main()
{
    int sock = nn_socket(AF_SP, NN_REQ); // 创建一个REQ类型的socket
    if (sock < 0) {
        fprintf(stderr, "nn_socket error: %s\n", nn_strerror(nn_errno()));
        return -1;
    }

    if (nn_connect(sock, SERVER_ADDRESS) < 0) { // 连接服务器地址
        fprintf(stderr, "nn_connect error: %s\n", nn_strerror(nn_errno()));
        nn_close(sock);
        return -1;
    }

    char *request = "123";
    int request_len = strlen(request) + 1;
    int bytes = nn_send(sock, request, request_len, 0); // 发送请求消息
    if (bytes < 0) {
        fprintf(stderr, "nn_send error: %s\n", nn_strerror(nn_errno()));
        nn_close(sock);
        return -1;
    }

    printf("client sent: %s\n", request);

    char *buf = NULL;
    bytes = nn_recv(sock, &buf, NN_MSG, 0); // 接收回复消息
    if (bytes < 0) {
        fprintf(stderr, "nn_recv error: %s\n", nn_strerror(nn_errno()));
        nn_close(sock);
        return -1;
    }

    printf("client received: %s\n", buf);

    nn_freemsg(buf); // 释放接收到的消息内存

    nn_close(sock); // 关闭socket

    return 0;
}

编译命令：

gcc server.c -o server -lnanomsg
gcc client.c -o client -lnanomsg

运行命令：

./server
./client

运行结果：

服务器端输出：

server started, waiting for client...
server received: 123

客户端输出：

client sent: 123
client received: abc

"status": 400, "error": "Bad Request", "path": "/req/rels"

你在进行的请求发生了错误，错误码为400，表示错误的请求。错误信息为"Bad Request"，说明请求的格式或参数不正确。请求路径为"/req/rels"，表示你尝试访问的资源路径是"/req/rels"。请检查你的请求格式和参数是否正确，并确保访问的资源路径是有效的。如果问题仍然存在，请提供更多详细信息以便我能够帮助你解决问题。