如何实现nanomsg跨语言调用：C、Python与Go语言绑定完整指南

屈游会

1168人浏览 · 2026-03-25 05:00:01

屈游会 · 2026-03-25 05:00:01 发布

如何实现nanomsg跨语言调用：C、Python与Go语言绑定完整指南

【免费下载链接】nanomsg nanomsg library 项目地址: https://gitcode.com/gh_mirrors/na/nanomsg

nanomsg是一个轻量级的消息传递库，提供了多种消息传递模式，支持跨平台和跨语言通信。本文将详细介绍如何在C、Python和Go语言中实现nanomsg的绑定调用，帮助开发者快速掌握跨语言消息传递的核心技术。

一、nanomsg C API基础

nanomsg的核心实现是用C语言编写的，提供了简洁而强大的API接口。所有其他语言的绑定都是基于这些C API开发的。

1.1 核心API函数

nanomsg的C API主要包含以下核心函数：

nn_socket(): 创建一个新的nanomsg套接字
nn_bind(): 将套接字绑定到指定地址
nn_connect(): 连接到远程地址
nn_send(): 发送消息
nn_recv(): 接收消息
nn_close(): 关闭套接字

这些函数定义在src/nn.h头文件中，是所有语言绑定的基础。

1.2 C语言示例

以下是一个简单的C语言示例，展示了如何使用nanomsg进行消息传递：

#include <nanomsg/nn.h>
#include <nanomsg/pair.h>
#include <stdio.h>
#include <string.h>

int main() {
    int sock = nn_socket(AF_SP, NN_PAIR);
    if (sock < 0) {
        fprintf(stderr, "nn_socket: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    if (nn_bind(sock, "inproc://test") < 0) {
        fprintf(stderr, "nn_bind: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    const char *msg = "Hello, nanomsg!";
    int bytes = nn_send(sock, msg, strlen(msg), 0);
    if (bytes < 0) {
        fprintf(stderr, "nn_send: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    char buf[1024];
    bytes = nn_recv(sock, buf, sizeof(buf), 0);
    if (bytes < 0) {
        fprintf(stderr, "nn_recv: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    printf("Received: %.*s\n", bytes, buf);
    nn_close(sock);
    return 0;
}

二、Python语言绑定实现

虽然nanomsg官方没有提供Python绑定，但社区已经开发了多个第三方库，如pynanomsg和nanomsg-python。

2.1 安装Python绑定

可以使用pip安装Python绑定：

pip install pynanomsg

2.2 Python示例

以下是一个使用pynanomsg的简单示例：

import nanomsg

sock = nanomsg.Socket(nanomsg.PAIR)
sock.bind('inproc://test')

sock.send(b'Hello, nanomsg!')
msg = sock.recv()
print(f"Received: {msg.decode()}")

sock.close()

Python绑定通过ctypes库调用nanomsg的C API，为Python开发者提供了简洁的接口。

三、Go语言绑定实现

Go语言的nanomsg绑定可以通过Go Modules安装，常用的库有github.com/nanomsg/nanomsg-go。

3.1 安装Go绑定

go get github.com/nanomsg/nanomsg-go

3.2 Go示例

以下是一个Go语言的nanomsg示例：

package main

import (
    "fmt"
    "github.com/nanomsg/nanomsg-go"
)

func main() {
    sock, err := nanomsg.NewSocket(nanomsg.PAIR)
    if err != nil {
        panic(err)
    }
    defer sock.Close()

    err = sock.Bind("inproc://test")
    if err != nil {
        panic(err)
    }

    err = sock.Send([]byte("Hello, nanomsg!"))
    if err != nil {
        panic(err)
    }

    msg, err := sock.Recv()
    if err != nil {
        panic(err)
    }

    fmt.Printf("Received: %s\n", string(msg))
}

Go绑定通过cgo技术调用nanomsg的C API，提供了类型安全的Go接口。

四、跨语言通信示例

下面我们演示一个C、Python和Go三种语言之间通信的示例。

4.1 C语言服务端

// server.c
#include <nanomsg/nn.h>
#include <nanomsg/reqrep.h>
#include <stdio.h>
#include <string.h>

int main() {
    int sock = nn_socket(AF_SP, NN_REP);
    if (sock < 0) {
        fprintf(stderr, "nn_socket: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    if (nn_bind(sock, "tcp://*:5555") < 0) {
        fprintf(stderr, "nn_bind: %s\n", nn_strerror(nn_errno()));
        return 1;
    }

    while (1) {
        char buf[1024];
        int bytes = nn_recv(sock, buf, sizeof(buf), 0);
        if (bytes < 0) {
            fprintf(stderr, "nn_recv: %s\n", nn_strerror(nn_errno()));
            break;
        }

        printf("Received: %.*s\n", bytes, buf);

        const char *reply = "Hello from C server";
        bytes = nn_send(sock, reply, strlen(reply), 0);
        if (bytes < 0) {
            fprintf(stderr, "nn_send: %s\n", nn_strerror(nn_errno()));
            break;
        }
    }

    nn_close(sock);
    return 0;
}

4.2 Python客户端

# client.py
import nanomsg

sock = nanomsg.Socket(nanomsg.REQ)
sock.connect('tcp://localhost:5555')

sock.send(b'Hello from Python client')
reply = sock.recv()
print(f"Received reply: {reply.decode()}")

sock.close()

4.3 Go客户端

// client.go
package main

import (
    "fmt"
    "github.com/nanomsg/nanomsg-go"
)

func main() {
    sock, err := nanomsg.NewSocket(nanomsg.REQ)
    if err != nil {
        panic(err)
    }
    defer sock.Close()

    err = sock.Connect("tcp://localhost:5555")
    if err != nil {
        panic(err)
    }

    err = sock.Send([]byte("Hello from Go client"))
    if err != nil {
        panic(err)
    }

    reply, err := sock.Recv()
    if err != nil {
        panic(err)
    }

    fmt.Printf("Received reply: %s\n", string(reply))
}