19.3 Boost Asio 多线程通信

多线程服务依赖于两个通用函数,首先boost::bind提供了一个高效的、简单的方法来创建函数对象和函数对象适配器,它的主要功能是提供了一种将函数和它的参数绑定到一起的方法,这种方法可以将具有参数的成员函数、普通函数以及函数对象转化为不带参数的函数对象。

当参数绑定后则下一步就需要使用多线程功能,Boost库中提供了boost::thread库,boost::thread可以用于创建线程、启动线程、等待线程执行结束以及线程间通信等多种操,有了这两个关键库那么我们只需要accept.accept(*sock)等待套接字上线,当有套接字上线后则自动创建MyThread子线程,使用该子线程维持会话,首先是服务端实现代码。

#include <iostream>
#include <boost/asio.hpp>
#include <boost/thread.hpp>

using namespace boost::asio;

std::string addr = "127.0.0.1";

// 创建子线程
void MyThread(boost::shared_ptr<ip::tcp::socket> socket)
{
// 获取当前IP信息
std::string local_address = socket->local_endpoint().address().to_string();
while (true)
{
try
{
if (addr == local_address)
{
char data[512];
size_t len = socket->read_some(buffer(data));
std::cout << data << std::endl;
}
}
catch (boost::system::system_error e)
{
return;
}
}
}

int main(int argc, char* argv[])
{
typedef boost::shared_ptr<ip::tcp::socket> socket_ptr;
io_service service;

// 绑定IP与端口地址
ip::tcp::endpoint ep(ip::tcp::v4(), 6666);
ip::tcp::acceptor accept(service, ep);

while (true)
{
socket_ptr sock(new ip::tcp::socket(service));

// 侦听套接字
accept.accept(*sock);

// 绑定套接字参数
boost::function0<void> function = boost::bind(MyThread, sock);

// 创建新的子线程
boost::thread threading(function);
}

system("pause");
return 0;
}

客户端代码如下所示,由于客户端无需实现多线程所以代码中只需要简单的调用socket.connect()链接到服务端,并调用write_some发送一条消息即可,代码如下图所示;

#include <iostream>
#include <string>
#include <boost/asio.hpp>

using namespace boost::asio;

int main(int argc, char *argv[])
{
io_service io_service;
ip::tcp::endpoint ep(ip::address::from_string("127.0.0.1"), 6666);
ip::tcp::socket socket(io_service);

// 链接到服务端
socket.connect(ep);

char buffer[1024] = "hello lyshark";

socket.write_some(boost::asio::buffer(buffer, 1024));

system("pause");
return 0;
}

运行上方服务端代码,然后开启三个客户端代码,读者可自行观察通信状态,此时三个客户端均实现了输出,如下图所示;