现在几乎所有C/C++的后台程序都需要进行网络通讯,其实现方法无非有两种:使用系统底层socket或者使用已有的封装好的网络库。本文对两种方式进行总结,并介绍一个轻量级的网络通讯库ZeroMQ。
1.基本的Scoket编程
关于基本的scoket编程网络上已有很多资料,作者在这里引用一篇文章中的内容进行简要说明。
基于socket编程,基本上就是以下6个步骤:
服务器端 #include#include #include #include #include #include #include #define MAXLINE 4096 int main(int argc, char** argv) { int listenfd, connfd; struct sockaddr_in servaddr; char buff[4096]; int n; if( (listenfd = socket(AF_INET, SOCK_STREAM, 0)) == -1 ){ printf("create socket error: %s(errno: %d)\n",strerror(errno),errno); exit(0); } memset(&servaddr, 0, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY); servaddr.sin_port = htons(6666); if( bind(listenfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) == -1){ printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno); exit(0); } if( listen(listenfd, 10) == -1){ printf("listen socket error: %s(errno: %d)\n",strerror(errno),errno); exit(0); } printf("======waiting for client's request======\n"); while(1){ if( (connfd = accept(listenfd, (struct sockaddr*)NULL, NULL)) == -1){ printf("accept socket error: %s(errno: %d)",strerror(errno),errno); continue; } n = recv(connfd, buff, MAXLINE, 0); buff[n] = '\0'; printf("recv msg from client: %s\n", buff); close(connfd); } close(listenfd); }
客户端 #include#include #include #include #include #include #include #define MAXLINE 4096 int main(int argc, char** argv) { int sockfd, n; char recvline[4096], sendline[4096]; struct sockaddr_in servaddr; if( argc != 2){ printf("usage: ./client \n"); exit(0); } if( (sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0){ printf("create socket error: %s(errno: %d)\n", strerror(errno),errno); exit(0); } memset(&servaddr, 0, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_port = htons(6666); if( inet_pton(AF_INET, argv[1], &servaddr.sin_addr) <= 0){ printf("inet_pton error for %s\n",argv[1]); exit(0); } if( connect(sockfd, (struct sockaddr*)&servaddr, sizeof(servaddr)) < 0){ printf("connect error: %s(errno: %d)\n",strerror(errno),errno); exit(0); } printf("send msg to server: \n"); fgets(sendline, 4096, stdin); if( send(sockfd, sendline, strlen(sendline), 0) < 0) { printf("send msg error: %s(errno: %d)\n", strerror(errno), errno); exit(0); } close(sockfd); exit(0); }
具体可参考: Linux Socket编程(不限Linux)
小结:直接基于socket编程看起来十分简单,但是要写出一个稳定、高性能的程序还是十分考验水平的,比如数据分包与重组,异步IO,并发访问,poll/select等,非大牛不能为之。鉴于此出现很多封装好的C/C++网络通讯库,或者叫消息中间件,下面进行介绍。
2.流行的通讯库/消息中间件
网络上各种各样的通讯中间件/MQ多不胜数。具作者所知,比较有名的有ACE、ICE、Boost::ASIO、MSMQ、ActiveMQ、RabbitMQ、ZeroMQ等等。
其中ACE、ICE是经典,网上资料很丰富,不过入门门槛较高,说白了就是有点难学难精。属于高端大气上档次的货。
Boost::ASIO作为大名鼎鼎的Boost模块之一,感觉很不错,只需引用.hpp文件,不需要动态库,性能据说也不错,跨平台,值得推荐和学习。不过没有最简单只有更简单,当有更好的选择时,Boost::ASIO的语法就略显复杂了。(不过还是强力推荐)。
MSMQ 微软的东西,用起来还可以,不过一般不推荐,毕竟linux下没人会用它。
JSM、ActiveMQ、RabbitMQ、ZeroMQ基本上是一类东西。activemq,基于jms稳定可靠安全。rabbitmq,基于erlang,充分利用并发和分布式特性。zeromq,号称世上最快消息内核。
|
|
ActiveMQ | RabbitMQ | ZeroMQ |
| 遵循规范 | JMS1.1及J2EE1.4 | AMPQ | --- |
| 架构模型 | 消息代理架构Broker | 消息代理架构Broker | C/S架构 |
| 实现语言 | Java | Erlang | C/C++ |
| 支持消息协议 | Stomp | AMPQ、Stomp等 | --- |
| 主要推动力量 | Apache、Redhat | Lshift、Vmware、SpringSource | iMatix |
| 支持编程语言 | C,Java,Python | C,Java,Python | C,Java,Python |
| 编程复杂度 | 复杂 | 简单 | 中等 |
| 持久化 | 支持 | 支持,不支持第三方数据库 | 发送端缓存 |
| 性能 | Normal | Normal | High |
| 内存使用率 | High | High | Normal |
下面是一个网上对消息系统的总结,也可以参考以下。
常见开源消息系统
3.最快的消息中间件zeroMQ
ZeroMQ简介
参考1: MQ(ZeroMQ)简介
参考2:ZeroMQ研究与应用分析[推荐]
参考3:高性能的通讯库-zeroMQ的几个高性能特征
参考4:ZeroMQ详细教程,从入门到深入,34篇