Muduo 网络编程示例(二) Boost.Asio 的聊天服务器

本文讲介绍一个与 Boost.Asio 的示例代码中的聊天服务器功能类似的网络服务程序,包括客户端 与服务端的 muduo 实现。这个例子的主要目的是介绍如何处理分包,并初步涉及 Muduo 的多线程功能 。Muduo 的下载地址: http://muduo.googlecode.com/files/muduo-0.1.7-alpha.tar.gz ,SHA1 873567e43b3c2cae592101ea809b30ba730f2ee6,本文的完整代码可在线阅读

http://code.google.com/p/muduo/source/browse/trunk/examples/asio/chat/ 。

TCP 分包

前面一篇《五个简单 TCP 协议》中处理的协议没有涉及分包,在 TCP 这种字节流协议上做应用层 分包是网络编程的基本需求。分包指的是在发生一个消息(message)或一帧(frame)数据时,通过一定的 处理,让接收方能从字节流中识别并截取(还原)出一个个消息。“粘包问题”是个伪问题。

对于短连接的 TCP 服务,分包不是一个问题,只要发送方主动关闭连接,就表示一条消息发送完毕 ,接收方 read() 返回 0,从而知道消息的结尾。例如前一篇文章里的 daytime 和 time 协议。

对于长连接的 TCP 服务,分包有四种方法:

1. 消息长度固定,比如 muduo 的 roundtrip 示例就采用了固定的 16 字节消息;

2. 使用特殊的字符或字符串作为消息的边界,例如 HTTP 协议的 headers 以 "rn" 为字段的分隔 符;

3. 在每条消息的头部加一个长度字段,这恐怕是最常见的做法,本文的聊天协议也采用这一办法;

4. 利用消息本身的格式来分包,例如 XML 格式的消息中 <root>...</root> 的配对 ,或者 JSON 格式中的 { ... } 的配对。解析这种消息格式通常会用到状态机。

在后文的代码讲解中还会仔细讨论用长度字段分包的常见陷阱。

聊天服务

本文实现的聊天服务非常简单,由服务端程序和客户端程序组成,协议如下:

* 服务端程序中某个端口侦听 (listen) 新的连接;

* 客户端向服务端发起连接;

* 连接建立之后,客户端随时准备接收服务端的消息并在屏幕上显示出来;

* 客户端接受键盘输入,以回车为界,把消息发送给服务端;

* 服务端接收到消息之后,依次发送给每个连接到它的客户端;原来发送消息的客户端进程也会收 到这条消息;

* 一个服务端进程可以同时服务多个客户端进程,当有消息到达服务端后,每个客户端进程都会收 到同一条消息,服务端广播发送消息的顺序是任意的,不一定哪个客户端会先收到这条消息。

* (可选)如果消息 A 先于消息 B 到达服务端,那么每个客户端都会先收到 A 再收到 B。

这实际上是一个简单的基于 TCP 的应用层广播协议,由服务端负责把消息发送给每个连接到它的客 户端。参与“聊天”的既可以是人,也可以是程序。在以后的文章中,我将介绍一个稍微复杂的一点的 例子 hub,它有“聊天室”的功能,客户端可以注册特定的 topic(s),并往某个 topic 发送消息,这 样代码更有意思。

时间: 2024-11-03 21:54:13

Muduo 网络编程示例(二) Boost.Asio 的聊天服务器的相关文章

Muduo 网络编程示例(七)“串并转换”连接服务器及其自动化测试

本文介绍如何使用 test harness 来测试一个具有内部逻辑的网络服务程序. 本文的代码见 http://code.google.com/p/muduo/source/browse/trunk/examples/multiplexer 下载地址: http://muduo.googlecode.com/files/muduo-0.2.0-alpha.tar.gz SHA1 checksum: 75a09a82f96b583004876e95105c679e64c95715 云风在他的博客中

Muduo 网络编程示例(六)限制服务器的最大并发连接数

本文已以大家都熟悉的 EchoServer 介绍如何限制服务器的并发连接数. 本文的代码见 http://code.google.com/p/muduo/source/browse/trunk/examples/maxconnection/ <Muduo 网络 编程示例 系列>计划中的第六篇文章原本是"用于测试两台机器的带宽的 pingpong 程序", pingpong 协议的程序已经在<muduo 与 boost asio 吞吐量对比>和<muduo

Muduo 网络编程示例之零:前言

陈硕 (giantchen_AT_gmail)Blog.csdn.net/Solstice Muduo 全系列文章列表: http://blog.csdn.net/Solstice/category/779646.aspx我将会写一系列文章,介绍用 muduo 网络库完成常见的 TCP 网络编程任务.目前计划如下: UNP 中的简单协议,包括 echo.daytime.time.discard 等.  Boost.Asio 中的示例,包括 timer2~6.chat 等. Java Netty 

Muduo 网络编程示例

我将会写一系列文章,介绍用 muduo 网络库完成常见的 TCP 网络编程任务.目前计划如下: UNP 中的简单协议,包括 echo.daytime.time.discard 等. Boost.Asio 中的示例, 包括 timer2~6.chat 等. Java Netty 中的示例,包括 discard.echo.uptime 等,其中的 discard 和 echo 带流量统计功能. Python twisted 中的示例,包括 finger01~07 用于测试两台机器的往返延迟的 rou

Muduo 网络编程示例(九)简单的消息广播服务

本文介绍用 muduo 实现一个简单的 topic-based 消息广播服务,这其实是"聊天室"的一个简单 扩展,不过聊天的不是人,而是分布式系统中的程序. 本文的代码见 http://code.google.com/p/muduo/source/browse/trunk/examples/hub 在分布式系统中,除了常用的 end-to-end 通信,还有一对多的广播通信.一提到"广播",或许 会让人联想到 IP 多播或 IP 组播,这不是本文的主题.本文将要谈的

Muduo 网络编程示例(四)Twisted Finger

Python Twisted 是一款非常好的网络库,它也采用 Reactor 作为网络编程的基本模型,所以从使 用上与 muduo 颇有相似之处.(当然,muduo 没有 deferreds)Finger 是 twisted 文档的一个经典 例子,本文展示如何用 muduo 来实现最简单的 finger 服务端.限于篇幅,只实现 finger01~07.代 码位于 examples/twisted/finger . 1 拒绝连接 什么都不做,程序空等. finger01.cc 1: #inclu

Muduo 网络编程示例(五)测量两台机器的网络延迟

本文介绍一个简单的网络程序 roundtrip,用于测量两台机器之间的网络延迟,即"往返时间 / round trip time / RTT".这篇文章主要考察定长 TCP 消息的分包,TCP_NODELAY 的作用. 本文的代码见 http://code.google.com/p/muduo/source/browse/trunk/examples/roundtrip/roundtrip.cc 测量 RTT 的办法很简单: host A 发一条消息给 host B,其中包含 host

Muduo 网络编程示例(一) 五个简单TCP协议

本文将介绍第一个示例:五个简单 TCP 网络服务协议,包括 echo (RFC 862).discard (RFC 863) .chargen (RFC 864).daytime (RFC 867).time (RFC 868),以及 time 协议的客户端.各协议的功 能简介如下: * discard - 丢弃所有收到的数据: * daytime - 服务端 accept 连接之 后,以字符串形式发送当前时间,然后主动断开连接: * time - 服务端 accept 连接之后,以 二进制形式

Muduo 网络编程示例(十)socks4a 代理服务器

本文介绍用 muduo 实现一个简单的 socks4a 代理服务器,代码见 http://code.google.com/p/muduo/source/browse/trunk/examples/socks4a/ . TCP 中继器 在实现 socks4a proxy 之前,我们先写一个功能更简单的网络程序-- TCP 中继器 (TCP relay),或者叫做穷人的 tcpdump (poor man's tcpdump). 一般情况下,客户端程序直接 连接服务端,如下图.有时候,我们想在 cl