libnanomsg详解

libnanomsg，或简称为nanomsg，是一个高性能的消息传递库，它为开发者提供了简单且高效的“可扩展协议”实现。以下是对libnanomsg的详细解析：

一、基本概述

项目地址：GitCode - 全球开发者的开源社区,开源代码托管平台或 https://github.com/nanomsg/nanomsg
编程语言：使用C语言编写，遵循C89标准，易于移植到多种平台。
依赖项：依赖于POSIX pthreads和BSD套接字，跨平台兼容性好。
构建系统：使用CMake作为构建系统，确保了在不同平台上的兼容性和易用性。

二、主要功能与特点

多种通信模式：
- 支持PAIR、BUS、REQREP、PUBSUB等多种通信模式，这些模式可以构建分布式系统的基本框架。
- 提供了请求/回复、发布/订阅、调查者/响应者等常见的消息传递模式。
多种传输方式：
- 支持TCP、UNIX套接字、WebSocket等多种传输方式，提供了灵活的通信选择。
高性能：
- 设计目标之一是高性能，适用于需要快速消息传递的应用场景。
- 对性能进行了优化，具有较高的运行效率和较低的内存开销。
跨平台：
- 支持Windows、Linux、MacOS X等多种操作系统，确保了项目的广泛适用性。
开源免费：
- 采用MIT许可证，开发者可以自由使用、修改和分发。
简单易用：
- 提供了简洁的API，开发者可以快速上手并集成到项目中。
- 将复杂的网络通信协议进行了抽象和封装，简化了分布式系统间的通信。

三、应用场景

分布式系统：
- 在分布式系统中，nanomsg可以作为节点间通信的基础设施，支持高效的计算任务分发和结果收集。
微服务架构：
- 在微服务架构中，服务之间需要高效的消息传递机制，nanomsg提供的多种协议可以满足不同服务间的通信需求。
实时数据处理：
- 在实时数据处理系统中，nanomsg的高性能特性可以确保数据的快速传递和处理。
物联网（IoT）：
- 在物联网应用中，nanomsg可以用于设备间的消息传递，支持设备间的实时通信和数据交换。

四、安装与编译

下载源代码并安装：

linux:

sudo apt-get install libnanomsg-dev

从源码编译安装：

git clone https://github.com/nanomsg/nanomsg.git
cd nanomsg
mkdir build
cd build
cmake ..
make
sudo make install

2.使用示例

服务端代码（server.c）：

#include "nn.h"
#include "reqrep.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define URL "tcp://127.0.0.1:12580"

int main() {
    int sock = nn_socket(AF_SP, NN_REP);
    if (sock < 0) {
        perror("nn_socket");
        exit(1);
    }

    if (nn_bind(sock, URL) < 0) {
        perror("nn_bind");
        exit(1);
    }

    char *buf = NULL;
    while (1) {
        int bytes = nn_recv(sock, &buf, NN_MSG, 0);
        if (bytes < 0) {
            perror("nn_recv");
            exit(1);
        }
        printf("Received: %s\n", buf);
        nn_freemsg(buf);

        const char *response = "World";
        bytes = nn_send(sock, response, strlen(response) + 1, 0);
        if (bytes < 0) {
            perror("nn_send");
            exit(1);
        }
    }

    nn_close(sock);
    return 0;
}

客户端代码（client.c）：

#include "nn.h"
#include "reqrep.h"
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define URL "tcp://127.0.0.1:12580"

int main() {
    int sock = nn_socket(AF_SP, NN_REQ);
    if (sock < 0) {
        perror("nn_socket");
        exit(1);
    }

    if (nn_connect(sock, URL) < 0) {
        perror("nn_connect");
        exit(1);
    }

    const char *msg = "Hello";
    int bytes = nn_send(sock, msg, strlen(msg) + 1, 0);
    if (bytes < 0) {
        perror("nn_send");
        exit(1);
    }

    char *buf = NULL;
    bytes = nn_recv(sock, &buf, NN_MSG, 0);
    if (bytes < 0) {
        perror("nn_recv");
        exit(1);
    }

    printf("Received: %s\n", buf);
    nn_freemsg(buf);

    nn_close(sock);
    return 0;
}

觉得有帮助的话，打赏一下呗。。