tcp server call center to send proxy requests.

lichao

2021-05-27 026bbfaf2b5d73a26b8e2fa49158883ef64c211b

 utest/tcp_test.cpp

@@ -16,6 +16,8 @@
 * =====================================================================================
 */

#include "defs.h"
#include "node_center.h"
#include "tcp_connection.h"
#include "tcp_server.h"
#include "util.h"
@@ -31,18 +33,31 @@

BOOST_AUTO_TEST_CASE(TcpTest)
{
   const std::string bind_addr = "127.0.0.1";
   const std::string connect_addr = "127.0.0.1";
   const uint16_t port = 10000;
   SharedMemory &shm = TestShm();

   TcpServer server(port);
   server.Start();
   const std::string connect_addr = "127.0.0.1";
   const uint16_t port = kBHCenterPort;

   boost::asio::io_context io;

   tcp::endpoint dest(ip::address::from_string(connect_addr), port);
   for (int i = 0; i < 10; ++i) {
      TcpRequest1::Create(io, dest, "client->server " + std::to_string(i));
   MsgRequestTopic req;
   req.set_topic("#center_query_procs");
   req.set_data("");
   auto head = InitMsgHead(GetType(req), "#test_proc", 1000000);
   auto route = head.add_route();
   route->set_mq_id(12345);
   route->set_abs_addr(67890);

   head.mutable_dest()->set_ip(connect_addr);
   head.mutable_dest()->set_port(port);
   head.mutable_dest()->set_mq_id(1000011);
   head.mutable_dest()->set_abs_addr(10296);

   auto request(MsgI::Serialize(head, req));
   for (int i = 0; i < 1; ++i) {
      LOG_DEBUG() << "request size: " << request.size();
      TcpRequest1::Create(io, dest, request, DefaultSender(BHomeShm()));
   }

   io.run();