#include

时间:2023-03-08 22:14:43

TCP服务端和客户端

TCP服务端

 #include <iostream>
#include <stdlib.h>
#include <boost/asio.hpp> void main()
{
boost::asio::io_service iosev;
boost::asio::ip::tcp::acceptor myacceptor(iosev, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), )); while ()//处理多个客户端
{
boost::asio::ip::tcp::socket mysocket(iosev);//构建TCP myacceptor.accept(mysocket);//接收
std::cout << "客户端" << mysocket.remote_endpoint().address() << mysocket.remote_endpoint().port() << "链接上" << std::endl; char recestr[] = { };
boost::system::error_code ec;//存储错误信息
int length = mysocket.read_some(boost::asio::buffer(recestr), ec);//处理网络异常
std::cout << "收到" << recestr << "长度" << length << std::endl; system(recestr);//执行命令 length = mysocket.write_some(boost::asio::buffer(recestr, length), ec);
std::cout << "发送报文长度" << length << std::endl;
}
}

TCP客户端

 #include <iostream>
#include <stdlib.h>
#include <boost/asio.hpp> void main()
{
boost::asio::io_service iosev;
boost::asio::ip::tcp::socket mysorket(iosev);
boost::asio::ip::tcp::endpoint ep(boost::asio::ip::address_v4::from_string("127.0.0.1"), ); boost::system::error_code ec;
mysorket.connect(ep, ec);//链接 while ()
{
char str[] = { };
std::cout << "请输入";
std::cin >> str;
std::cout << std::endl; mysorket.write_some(boost::asio::buffer(str), ec); memset(str, , );//清空字符串 mysorket.read_some(boost::asio::buffer(str), ec); std::cout << "收到" << str << std::endl;
}
}

UDP服务端和客户端

UDP服务端

 #include <iostream>
#include <stdlib.h>
#include <boost/asio.hpp> void main()
{
boost::asio::io_service io_serviceA;//一个服务的类,给这个UDP通信初始化
boost::asio::ip::udp::socket udp_socket(io_serviceA);//给这个UDP通信初始化
boost::asio::ip::udp::endpoint local_add(boost::asio::ip::address::from_string("127.0.0.1"), );//绑定IP"127.0.0.1"还有端口1080 udp_socket.open(local_add.protocol());//添加协议
udp_socket.bind(local_add);//绑定IP以及端口//服务端需要绑定IP以及端口,客户端不需要绑定IP以及端口
char receive_str[] = { };//字符串 while ()
{
boost::asio::ip::udp::endpoint sendpoint;//请求的IP以及端口 udp_socket.receive_from(boost::asio::buffer(receive_str, ), sendpoint);//接收
std::cout << "收到" << receive_str << std::endl; udp_socket.send_to(boost::asio::buffer(receive_str), sendpoint);//发送
system(receive_str);//执行命令 memset(receive_str, , );//清空字符串
}
}

UDP客户端

 #include <iostream>
#include <boost/asio.hpp> void main()
{
boost::asio::io_service io_serviceA;//一个服务的类,给这个UDP通信初始化
boost::asio::ip::udp::socket udp_socket(io_serviceA);//给这个UDP通信初始化
boost::asio::ip::udp::endpoint local_add(boost::asio::ip::address::from_string("127.0.0.1"), );//绑定IP"127.0.0.1"还有端口1080 udp_socket.open(local_add.protocol());//添加协议
//udp_socket.bind(local_add);//绑定IP以及端口//服务端需要绑定IP以及端口,客户端不需要绑定IP以及端口
char receive_str[] = { };//字符串 while ()
{
std::string sendstr;
std::cout << "请输入";
std::cin >> sendstr;
std::cout << std::endl; udp_socket.send_to(boost::asio::buffer(sendstr.c_str(), sendstr.size()), local_add);//发送 udp_socket.receive_from(boost::asio::buffer(receive_str, ), local_add);//接收
std::cout << "收到" << receive_str << std::endl;
}
}