bstar=bstar_new(BSTAR_PRIMARY,"tcp://*:5003","tcp://localhost:5004");bstar_voter(self->bstar,"tcp://*:5556",ZMQ_ROUTER,s_snapshots,self);self->port=5556;self->peer=5566;self->primary=TRUE;}elseif(argc==2&&streq(argv[1],"-b")){zclock_log("I:backuppassive,waitingforprimary(active)");self->bstar=bstar_new(BSTAR_BACKUP,"tcp://*:5004","tcp://localhost:5003");bstar_voter(self->bstar,"tcp://*:5566",ZMQ_ROUTER,s_snapshots,self);self->port=5566;-IMDN开发者社群-imdn.cn"> bstar=bstar_new(BSTAR_PRIMARY,"tcp://*:5003","tcp://localhost:5004");bstar_voter(self->bstar,"tcp://*:5556",ZMQ_ROUTER,s_snapshots,self);self->port=5556;self->peer=5566;self->primary=TRUE;}elseif(argc==2&&streq(argv[1],"-b")){zclock_log("I:backuppassive,waitingforprimary(active)");self->bstar=bstar_new(BSTAR_BACKUP,"tcp://*:5004","tcp://localhost:5003");bstar_voter(self->bstar,"tcp://*:5566",ZMQ_ROUTER,s_snapshots,self);self->port=5566; - IMDN开发者社群-imdn.cn">
登录
首页 » Linux编程 » ZeroMQ高级发布订阅模式

ZeroMQ高级发布订阅模式

于 2022-07-10 发布 文件大小:116.26 kB
0 201
下载积分: 2 下载次数: 1

代码说明:

Clone server, Model Six (clonesrv6.c): main task setupint main (int argc, char *argv []){clonesrv_t *self = (clonesrv_t *) zmalloc (sizeof (clonesrv_t));if (argc == 2 && streq (argv [1], "-p")) {zclock_log ("I: primary active, waiting for backup (passive)");self->bstar = bstar_new (BSTAR_PRIMARY, "tcp://*:5003","tcp://localhost:5004");bstar_voter (self->bstar, "tcp://*:5556", ZMQ_ROUTER, s_snapshots, self);self->port = 5556;self->peer = 5566;self->primary = TRUE;}elseif (argc == 2 && streq (argv [1], "-b")) {zclock_log ("I: backup passive, waiting for primary (active)");self->bstar = bstar_new (BSTAR_BACKUP, "tcp://*:5004","tcp://localhost:5003");bstar_voter (self->bstar, "tcp://*:5566", ZMQ_ROUTER, s_snapshots, self);self->port = 5566;

下载说明:请别用迅雷下载,失败请重下,重下不扣分!

发表评论

0 个回复

  • Linux 进线控制
    首先,父进程执行fork()函数创建子进程,在子进程中实现两个文件的建立,父进程等待子进程执行完后,通过pthread_create()创建两个线程threads0、threads1。然后由两个线程分别统计两个文件中的字符数,处理完成后分别调用pthread_exit()函数退出。父进程等待线程退出后打印出总字符数total。父进程调用vfork()函数创建子进程,使用execl()函数调用程序change,将两个文件中的小写字母转换成大写字母,执行完成后exit()退出。父进程等待整个过程执行完之后,exit(0)退出。
    2022-01-25 20:01:06下载
    积分:1
  • usbredir 重定向,桌面云,usb外设
    usbredir是一个网络协议,通过网络连接发送usb设备传输。同时它也是一个执行这个协议的软件包,提供一个解析库、一个usbredirhost库和几个实用程序,来实现这个协议。
    2022-02-19 22:47:01下载
    积分:1
  • Servlety 至 klasy,których celem 戏谑 przetwarzanie żądań HTTP 我 generowanie zawartości która będzie ode
    Servlety 至 klasy,których celem 戏谑 przetwarzanie żądań HTTP 我 generowanie zawartości która będzie odesłana w odpowiedzi na te żądania。Innymi słowy servlety służą implementacji dynamicznych aplikacji WWW 做 Z założenia servlety mogą obsługiwać także protokoły inne niż HTTP、 jednak w praktyce ich użycie ogranicza się niemal wyłącznie 做 implementacji aplikacji WWW opartych na HTTP。Możemy zatem myśleć o servletach jak o narzędziu służącym tylko 我 wyłącznie 做大话 właśnie celu。
    2022-03-10 22:52:57下载
    积分:1
  • linux QT坦克大战
    工具:QT4  C++  Sql 实现功能:具有创建数据库文件(.db文件)、保存记录、遍历、删除、查询、修改功能 代码运行方式 1.QT4运行这个程序 2.点击“创建/打开数据”即可创建或打开相应的.db数据库...
    2022-04-14 12:05:39下载
    积分:1
  • C语言,处理批量导数的源代码分享中中中中中中中中
    资源描述C语言,处理批量导数的源代码分享,C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享C语言,处理批量导数的源代码分享
    2022-03-19 14:53:55下载
    积分:1
  • mini2440 上MINI emc2 的下载问题件
     mini2440 上MINI emc2 上的下载文件 ,如果有MINI2440的可以测试一下哦 !
    2022-09-13 21:00:04下载
    积分:1
  • OK6410开发板和PC机上的客户端/服务器序,系统为linux开发平台
    OK6410开发板和PC机上的客户端/服务器程序,系统为linux开发平台
    2022-03-01 20:41:55下载
    积分:1
  • zxcjkucoack zxCIjicnscf ionhjzxcvonhs iozCJiovg
    2kjiilnfhi sf sfojmsfs fasfasf sf saf  asdf asf sdg ad gdf gd ghdh dh df hdh dh d hdfhds ghdh dh 
    2022-02-21 10:57:52下载
    积分:1
  • libev是linux系统事件的lib
    libev是Linux事件lib,你可以得到它,学习它,它可能对你有用,程序在Linux系统上;
    2023-04-14 14:05:03下载
    积分:1
  • SOCKET 通讯
    简单易懂,本人也刚刚学习SOCKET编程。上传给大家分享一下,具体内容大家自己看看吧
    2022-05-22 11:37:21下载
    积分:1
  • 696516资源总数
  • 106914会员总数
  • 0今日下载