| | |
|---|
| | | |
|---|
| | | # 1. 实例 |
|---|
| | | |
|---|
| | | 以下实例代码在`demo`文件夹下 |
|---|
| | | ## 1.1 Bus模式 |
|---|
| | | Source |
|---|
| | | **Source** |
|---|
| | | |
|---|
| | | `dgram_mod_bus.c` |
|---|
| | | |
|---|
| | | 编译 |
|---|
| | | **编译** |
|---|
| | | |
|---|
| | | 安装好so包后，用如下的方式编译，shm_queue是通信队列包，usgcommon是公共包，pthread是系统的线程包 |
|---|
| | | `g++ dgram_mod_bus.c -mcx16 -std=c++11 -lshm_queue -lusgcommon -lpthread` |
|---|
| | | |
|---|
| | | 演示 |
|---|
| | | **演示** |
|---|
| | | |
|---|
| | | 启动bus `./dgram_mod_bus server 8`。然后打开两个客户端连接bus， 第一个客户端订阅 "news", 第二个客户端发布 "news". 第一个客户端会收到第二个客户端推送的信息。 |
|---|
| | | |
|---|
| | |
|---|
| | | |
|---|
| | | ## 1.2 req_rep模式, 适应于注册 |
|---|
| | | |
|---|
| | | Source `dgram_mod_req_rep.c` |
|---|
| | | **Source** `dgram_mod_req_rep.c` |
|---|
| | | |
|---|
| | | 编译 同上 |
|---|
| | | **编译** 同上 |
|---|
| | | |
|---|
| | | 演示 |
|---|
| | | **演示** |
|---|
| | | |
|---|
| | | ``` |
|---|
| | | ## 启动注册中心 |
|---|
| | |
|---|
| | | ``` |
|---|
| | | |
|---|
| | | ## survey模式， 适应于心跳 |
|---|
| | | Source `dgram_mod_survey.c` |
|---|
| | | **Source** `dgram_mod_survey.c` |
|---|
| | | |
|---|
| | | 编译 同上 |
|---|
| | | **编译** 同上 |
|---|
| | | |
|---|
| | | **演示** |
|---|
| | | 启动心跳中心 |
|---|
| | | ``` |
|---|
| | | $ ./dgram_mod_survey server 3 |
|---|
