NNG（nanomsg-next-generation）：轻量级无代理消息传递库

1. 项目介绍

NNG是nanomsg的一个下一代实现，它提供了一种轻量级的、无需中间件的通信框架，用于构建可靠的分布式系统。这个库支持多种消息传递模式，如请求/响应、发布/订阅、对等点等，旨在简化异步I/O编程，提高可靠性和可扩展性。NNG的设计目标包括生产环境稳定性、易移植性、维护性和可扩展性。

2. 项目快速启动

安装依赖

在开始前，确保你的系统安装了C99兼容的编译器（如GCC或Clang）以及CMake版本至少为3.13。推荐使用Ninja构建系统，如果你还没有，可以安装它：

对于Ubuntu/Debian:

sudo apt-get install cmake ninja-build

对于CentOS/RHEL:

sudo yum install cmake ninja-build

对于macOS (使用Homebrew):

brew install cmake ninja

获取源码并构建

从GitHub克隆NNG仓库：

git clone https://github.com/nanomsg/nng.git
cd nng

然后执行以下命令进行配置、构建和安装：

mkdir build && cd build
cmake -GNinja ..
ninja
sudo ninja install

示例程序

下面是一个简单的使用NNG TCP传输发送和接收消息的例子：

sender.c 文件：

#include <nng/nng.h>
#include <stdio.h>

int main() {
    int       result;
    nng_socket sock;

    // 打开一个TCP推送者 socket
    result = nng_rep0_open(&sock);
    if (result != 0) {
        printf("Error opening socket: %s\n", nng_strerror(result));
        return 1;
    }

    // 绑定到端口 5555
    result = nng_listen(sock, "tcp://127.0.0.1:5555", NULL, 0);
    if (result != 0) {
        printf("Error listening: %s\n", nng_strerror(result));
        nng_close(sock);
        return 1;
    }

    // 接收到消息时，回复"Hello, World!"
    while (1) {
        uint8_t data[] = "Hello, World!";
        nng_sendv(sock, &data, sizeof(data), NULL, 0, 0);
    }

    nng_close(sock);
    return 0;
}

receiver.c 文件：

#include <nng/nng.h>
#include <stdio.h>

int main() {
    int       result;
    nng_socket sock;

    // 打开一个TCP接收者 socket
    result = nng_req0_open(&sock);
    if (result != 0) {
        printf("Error opening socket: %s\n", nng_strerror(result));
        return 1;
    }

    // 连接到本地端口 5555
    result = nng_dial(sock, "tcp://127.0.0.1:5555", NULL, NNG_FLAG_NONBLOCK);
    if (result != 0) {
        printf("Error dialing: %s\n", nng_strerror(result));
        nng_close(sock);
        return 1;
    }

    // 发送一个空消息，然后接收并打印服务器的回复
    nng_sendv(sock, NULL, 0, NULL, 0, 0);
    void *buf;
    size_t sz;
    result = nng_recv_alloc_msg(sock, &msg, 0);
    if (result == 0) {
        buf = nng_msg_body(msg);
        sz = nng_msg_len(msg);
        printf("Received message: %.*s\n", (int)sz, (char*)buf);
        nng_msg_free(msg);
    } else {
        printf("Error receiving: %s\n", nng_strerror(result));
    }

    nng_close(sock);
    return 0;
}

编译这两个文件并运行接收器，然后运行发送器：

gcc sender.c -o sender -lnng
gcc receiver.c -o receiver -lnng
./receiver & # 运行接收器
./sender         # 运行发送器

3. 应用案例和最佳实践

• 微服务通信：NNG 可以用来连接分布式系统中的不同组件，例如微服务间的通信。
• 实时数据流：利用NNG的发布/订阅模型，可以构建实时数据流系统，允许多个客户端订阅同一数据源。
• 跨平台网络应用：由于其广泛的平台支持，NNG适用于需要在多个操作系统上运行的应用程序。

最佳实践包括：

• 使用非阻塞模式，特别是在处理高并发场景时。
• 对错误处理进行充分测试，确保在异常情况下程序不会崩溃。
• 利用线程池提升性能和可扩展性。
• 选择适当的协议类型来匹配特定的通信需求。

4. 典型生态项目

• nnbench: 提供了一个基准工具，用于评估NNG的性能。
• libzmq：ZeroMQ是一个高级的消息中间件库，NNG的一些设计灵感来源于此。
• nngcpp：一个C++包装器库，提供了更面向对象的API来使用NNG。
• nng-pubsub: 一个示例项目，演示如何使用NNG实现发布/订阅模式。

通过这些生态项目，开发者可以获得更多的工具和资源来更好地集成和利用NNG。