服务器和客户端同时使用BOOST-ASIO
Server and Client at same time with Boost-Asio
我是57岁的ASPNET程序员。因为我是唯一一开始就与C 一起工作的人,所以我的老板要求我为需要一个具有非常具体特征的通信代理的客户服务。它可以在多个平台上作为守护程序运行,并有时是客户端和服务器。我不太了解,但是我必须解决这个问题,并在Boost/asio库中找到了机会。
我是Boost-Asio的新手,并且阅读了我创建的服务器和TCP套接字客户端的文档,该客户端可以完美交换消息,并且双向,完整的双工。
我阅读了几篇文章,他们要求提供我想要的相同内容,但是所有答案都建议完整的双工,就像这意味着在同一程序中拥有客户端和服务器。事实并非如此。完整双工的定义是指从相同连接编写和读取的能力,默认情况下每个TCP连接都是完整的双工。
我需要制作两个程序可以接受另一个程序引发的连接。这两个程序之间将没有永久性的联系。有时,其中一个会要求建立连接,而在其他时候,另一个会提出此请求,两者都需要聆听,接受连接,交换一些消息并终止连接直到建立新请求。
。我所做的服务器似乎陷入了聆听端口的过程中,以查看连接是否进入,我无法继续进行该过程以创建插座并请求与其他程序的连接。我需要线程,但我对它们了解不足。
有可能吗?
正如我所说,我是Boost/asio的新手,我试图遵循一些线程和coroutines的文档。然后,我将客户端代码放入一种方法中,将服务器放在另一种方法中。:
int main(int argc, char* argv[])
{
try
{
boost::thread t1(&server_agent);
boost::thread t2(&client_agent);
// wait
t1.join();
t2.join();
return 0;
}
catch (std::exception& e)
{
std::cerr << "Exception: " << e.what() << "n";
}
return 0;
}
和两个coroutines:
void client_agent() {
parameters param;
param.load();
boost::asio::io_service io_service1;
tcp::resolver resolver(io_service1);
char port[5];
_itoa(param.getNrPortaServComunic(), port, 10);
auto endpoint_iterator = resolver.resolve({ param.getIPServComunicPrincipal(), port });
std::list<client> clients;
client c(io_service1, endpoint_iterator, param);
while (true)
{
BOOL enviada = FALSE;
while (true) {
if (!enviada) {
std::cout << "sending a messagen";
int nr = 110;
message msg(nr, param);
c.write(msg);
enviada = TRUE;
}
}
}
c.close();
}
void server_agent() {
parameters param;
param.load();
boost::asio::io_service io_service1;
std::list<server> servers;
tcp::endpoint endpoint(tcp::v4(), param.getNrPortaAgenteServ());
servers.emplace_back(io_service1, endpoint);
io_service1.run();
}
我将一个端口用于客户端端点和服务器端点的其他端口。这是对的吗?需要?
它开始看起来像是在起作用。每种方法都同时运行,但随后我在io_service1.run(server_agent方法的最后一行(上获得线程分配错误:
boost :: exception_detail :: clone_impl>在内存位置0x0118c61c。
任何建议?
您正在描述UDP客户端/服务器应用程序。但是您的实施注定会失败。想想在单个线程中运行的ASIO服务器或客户端。
以下代码只是为了使您有一个想法。我没有试图编译它。客户端非常相似,但可能需要发送缓冲区,这显然取决于应用。
。这是一个缩短版本,因此您可以理解。在最终应用程序中,您想添加接收超时等。TCP服务器具有相同的原理,并带有添加的async_listen调用。连接的插座可以存储在shared_ptr中,并被兰伯达(Lambdas(捕获,几乎会神奇地破坏。
服务器基本上是相同的,除了没有持续的读数正在进行。如果在同一过程中同时运行服务器和客户端,则可以依靠运行((由于服务器而循环,但是如果没有,则必须为每个连接调用Run((。run((将在交换结束时退出。
using namespace boost::asio; // Or whichever way you like to shorten names
class Server
{
public:
Server(io_service& ios) : ios_(ios) {}
void Start()
{
// create socket
// Start listening
Read();
}
void Read()
{
rxBuffer.resize(1024)
s_.async_receive_from(
buffer(rxBuffer),
remoteEndpoint_,
[this](error_code ec, size_t n)
{
OnReceive(ec, n); // could be virtual, if done this way
});
}
void OnReceive(error_code ec, size_t n)
{
rxBuffer_.resize(n);
if (ec)
{
// error ... stops listen loop
return;
}
// grab data, put in txBuffer_
Read();
s_.async_send_to(
buffer(txBuffer_),
remoteEndpoint_,
[this, msg](error_code ec, size_t n)
{
OnTransmitDone(ec, n);
});
}
void OnTransmitDone(error_code ec, size_t n)
{
// check for error?
txBuffer_.clear();
}
protected:
io_service& ios_;
ip::udp::socket s_;
ip::udp::endpoint remoteEndpoint_; // the other's address/port
std::vector<char> rxBuffer_; // could be any data type you like
std::vector<char> txBuffer_; // idem All access is in one thread, so only
// one needed for simple ask/respond ops.
};
int main()
{
io_service ios;
Server server(ios); // could have both server and client run on same thread
// on same io service this way.
Server.Start();
ios_run();
// or std::thread ioThread([&](){ ios_.run(); });
return 0;
}
- boost::asio UDP 广播客户端仅接收"fast"数据包
- TCP 服务器的异步读取使用 boost::asio 打印客户端套接字发送的数据
- 服务器和客户端同时使用BOOST-ASIO
- 使用带有SSL(HTTPS)的Boost-Beast(ASIO)HTTP客户端
- boost::asio::ip::tcp::iostream,先启动客户端,然后等待服务器
- C 设计:多个TCP客户端,Boost ASIO和观察者
- 带有 TLS v. 1.2 和 SSL v.3 电子邮件客户端的 Boost.Asio 上下文:ssl3 警报意外消息
- Boost ASIO async_read不是从客户端读取数据
- Boost asio,单个TCP服务器,多个客户端
- 基于BOOST :: ASIO-慢慢http客户端 - (转移块)
- 证书验证在客户端服务器通信中使用boost :: asio和openssl失败
- 如何通过Boost ASIO将OpenNi Depthmap发送给客户端
- Boost Asio,异步 UDP 客户端 - 关机时崩溃
- UDP Boost ASIO 异步客户端挂起
- ASIO 客户端服务器在同一台 PC 上连接正常,但在本地网络上出现故障
- 如何使用boost asio将端口正确随机分配给测试HTTP服务器
- boost::asio客户端连接停止接收数据
- 增强asio客户端身份验证
- 使boost http客户端
- boost.asio :多端口应用层协议