nanomsg的使用与分析

柔情只为你懂 2022-08-20 06:25 985阅读 0赞

本文对nanomsg进行系统讲解（ socket不同类型的区别）：

1.pull/push和rep/req的区别：

对于pull/push，客户端为push，其send数据后，server端会立即接收到

对于rep/req，客户端为req，其send数据后，客户端并不会立即发送给client，客户端必须再执行recv调用后，才会真正send数据

2. pair和req/req区别：

pair中，客户端只要send数据，server端就会接收到，客户端不必连续执行send，recv。但是，pair是一对一的，也就是说

附：

libc.h在linux是找不到的（XOS下才有），按照如下方法换成linux的.h，编译的时候要加上-pthread和最后的-lanl选项

//\#include <libc.h>  
  
\#include <unistd.h>  
\#include <string.h>  
\#include <pthread.h>

gcc -pthread reqrep.c /usr/local/lib/libnanomsg.a -o reqrep -lanl

Socket设置

![prio1.png][]

int req;
    int sndprio;
    char buf [64];
    
    /*  Open a REQ socket. */
    nn_init ();
    req = nn_socket (AF_SP, NN_REQ);
    
    /*  Connect to 3 servers in New York and 1 in London. */
    sndprio = 1;
    nn_setsockopt (req, NN_SOL_SOCKET, NN_SNDPRIO, &sndprio, sizeof (int));
    nn_connect (req, "tcp://newyorksrv001");
    nn_connect (req, "tcp://newyorksrv002");
    nn_connect (req, "tcp://newyorksrv003");
    sndprio = 2;
    nn_setsockopt (req, NN_SOL_SOCKET, NN_SNDPRIO, &sndprio, sizeof (int));
    nn_connect (req, "tcp://londonsrv001");
    
    /*  Do your work. */
    while (1) {
        nn_send (req, "MyRequest", 9, 0);
        nn_recv (req, buf, sizeof (buf), 0);
        process_reply (buf);
    }
    
    /*  Clean up. */
    nn_close (req);
    nn_term ();

[prio1.png]: /images/20220731/284fe6c287344d0989470c2456f88663.png

发表评论取消回复

表情：

评论列表（有 0 条评论，985人围观）

还没有评论，来说两句吧...

相关阅读

相关 Emma使用与分析

\什么是Emma EMMA 是一个开源、面向 Java 程序测试覆盖率收集和报告工具。它通过对编译后的 Java 字节码文件进行插装，在测试执行过程中收集覆盖率信息，并通过

悠悠/ 2023年10月17日 19:41/ 0 赞/ 9 阅读

相关 nanomsg的使用与分析

本文对nanomsg进行系统讲解（ socket不同类型的区别）： 1.pull/push和rep/req的区别：对于pull/push，客户端为push，其s

柔情只为你懂/ 2022年08月20日 06:25/ 0 赞/ 986 阅读

相关 VS2015编译生成nanomsg库文件

nanomsg是zeromq的轻量级版本,并且使用的是C语言(目前还不太成熟). 具体的情况介绍可以参考 [nanomsg官网][nanomsg]

拼搏现实的明天。/ 2022年08月20日 05:17/ 0 赞/ 363 阅读

相关 Hystrix 使用与分析

http://hot66hot.iteye.com/blog/2155036 转载请注明出处哈:http://hot66hot.iteye.com/blog/2155036

ゞ浴缸里的玫瑰/ 2022年07月14日 06:26/ 0 赞/ 180 阅读

相关 Hystrix 使用与分析

一:为什么需要Hystrix? 在大中型分布式系统中，通常系统很多依赖(HTTP,hession,Netty,Dubbo等)，如下图: ![887e7862-578a-

朴灿烈づ我的快乐病毒、/ 2022年06月17日 06:19/ 0 赞/ 285 阅读

相关 Hystrix 使用与分析

转载请注明出处哈:http://hot66hot.iteye.com/blog/2155036 -------------------- 一:为什么需要Hystrix

忘是亡心i/ 2022年06月14日 09:37/ 0 赞/ 195 阅读

相关 Hystrix 使用与分析

转载请注明出处哈:http://hot66hot.iteye.com/blog/2155036 -------------------- 一:为什么需要Hystri

我不是女神ヾ/ 2022年06月14日 00:41/ 0 赞/ 183 阅读

相关 Transition的相关分析与使用

`Transition`:意“过渡”，从字面意思上理解，就是从一种状态到另一种状态的切换过程，同样，对于`Android`中，其实现了`UI`状态的切换，其中包含了同一个`Ac

以你之姓@/ 2022年06月11日 02:17/ 0 赞/ 151 阅读

相关 nanomsg编译与测试

官网 [https://nanomsg.org/][https_nanomsg.org] 源码下载 [https://github.com/nanomsg/nanomsg

不念不忘少年蓝@/ 2022年05月09日 23:08/ 0 赞/ 234 阅读

相关 [Curator] Tree Cache 的使用与分析

[为什么80%的码农都做不了架构师？>>> ][80_] ![hot3.png][] Tree Cache 使用zk路径下所有节点数据作为缓存。这个类会监控ZK的一个

深碍√TFBOYSˉ_/ 2022年01月15日 06:53/ 0 赞/ 605 阅读