从 boost asio 套接字读取并打印到终端

发布于 2024-11-18 00:53:22 字数 1907 浏览 1 评论 0原文

我想使用 boost asio 套接字将消息从服​​务器发送到客户端,然后将其打印到客户端。我正在尝试发送消息“你好”。这不起作用。我该如何解决这个问题? 谢谢!

客户端:

#include <boost/asio.hpp>
#include <iostream>
#include <string>
using namespace std;
int main (int argc, char* argv[]) {
 try {
  boost::asio::io_service io_service;
  boost::asio::ip::tcp::resolver::query query("localhost", "41005");
  boost::asio::ip::tcp::resolver resolver(io_service);
  boost::asio::ip::tcp::resolver::iterator destination = resolver.resolve(query);
  boost::asio::ip::tcp::resolver::iterator end ;
  boost::asio::ip::tcp::endpoint endpoint;


  while ( destination != end ) {
     endpoint = *destination++;
     std::cout<<endpoint<<std::endl;
  }

  boost::asio::ip::tcp::socket socket(io_service);
  socket.connect(endpoint);
  boost::array< char, 128 > buf;
  boost::system::error_code error;
  std::size_t length = boost::asio::read(socket, boost::asio::buffer(buf, 512), boost::asio::transfer_all(), error);
  cout << length;
 }
 catch (std::exception& e)
 {
   std::cerr << e.what() << std::endl;
 }
 return 0;
}

服务器:

#include <boost/asio.hpp>
#include <iostream>
#include <string>
using namespace std;

int main () {

try {
  boost::asio::io_service io_service;
  boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 41005));

  for (; ;) {
     std::cout<<"Listening to"<<std::endl;
     boost::asio::ip::tcp::socket socket(io_service);
     acceptor.accept(socket);

     std::string message = "hello";
     boost::system::error_code ignored_error;
     boost::asio::write(socket, boost::asio::buffer(message), boost::asio::transfer_all(), ignored_error);
  }
}
catch (std::exception& e)
{
  std::cerr << e.what() << std::endl;
}
return 0;

}

I want to use boost asio sockets to send a message from the server to the client and then print it out to the client terminal. I am trying to send the message "hello". It doesn't work. How can i fix this?
Thanks!

client:

#include <boost/asio.hpp>
#include <iostream>
#include <string>
using namespace std;
int main (int argc, char* argv[]) {
 try {
  boost::asio::io_service io_service;
  boost::asio::ip::tcp::resolver::query query("localhost", "41005");
  boost::asio::ip::tcp::resolver resolver(io_service);
  boost::asio::ip::tcp::resolver::iterator destination = resolver.resolve(query);
  boost::asio::ip::tcp::resolver::iterator end ;
  boost::asio::ip::tcp::endpoint endpoint;


  while ( destination != end ) {
     endpoint = *destination++;
     std::cout<<endpoint<<std::endl;
  }

  boost::asio::ip::tcp::socket socket(io_service);
  socket.connect(endpoint);
  boost::array< char, 128 > buf;
  boost::system::error_code error;
  std::size_t length = boost::asio::read(socket, boost::asio::buffer(buf, 512), boost::asio::transfer_all(), error);
  cout << length;
 }
 catch (std::exception& e)
 {
   std::cerr << e.what() << std::endl;
 }
 return 0;
}

server:

#include <boost/asio.hpp>
#include <iostream>
#include <string>
using namespace std;

int main () {

try {
  boost::asio::io_service io_service;
  boost::asio::ip::tcp::acceptor acceptor(io_service, boost::asio::ip::tcp::endpoint(boost::asio::ip::tcp::v4(), 41005));

  for (; ;) {
     std::cout<<"Listening to"<<std::endl;
     boost::asio::ip::tcp::socket socket(io_service);
     acceptor.accept(socket);

     std::string message = "hello";
     boost::system::error_code ignored_error;
     boost::asio::write(socket, boost::asio::buffer(message), boost::asio::transfer_all(), ignored_error);
  }
}
catch (std::exception& e)
{
  std::cerr << e.what() << std::endl;
}
return 0;

}

如果你对这篇内容有疑问,欢迎到本站社区发帖提问 参与讨论,获取更多帮助,或者扫码二维码加入 Web 技术交流群。

扫码二维码加入Web技术交流群

发布评论

需要 登录 才能够评论, 你可以免费 注册 一个本站的账号。

评论(1

dawn曙光 2024-11-25 00:53:22

经典错误:“acceptor.accept”方法是阻塞调用,因此永远不会调用 hello 部分。

我们的 COut 朋友将一如既往地帮助您:

...
std::cout<<"发送问候"<

classic error: the "acceptor.accept" method is a blocking call, so the hello part is never called.

Our COut friend would help you, as allways:

...
std::cout<<"Sending hello"<

~没有更多了~
我们使用 Cookies 和其他技术来定制您的体验包括您的登录状态等。通过阅读我们的 隐私政策 了解更多相关信息。 单击 接受 或继续使用网站,即表示您同意使用 Cookies 和您的相关数据。
原文