BOOST ASIO - Как написать консольный сервер - PullRequest
Новая
       7

BOOST ASIO - Как написать консольный сервер

1 голос
/ 06 марта 2011

Я должен написать асинхронный TCP-сервер.Сервер TCP должен управляться консолью (например: удалить клиента, показать список всех подключенных клиентов и т. Д.)

Проблема заключается в следующем: как подключить (или записать) консоль, которая может выполнять вызовы вышефункциональные возможности.Эта консоль должна быть клиентом?Должен ли я запускать этот консольный клиент как отдельный поток?

Я прочитал много учебников и не смог найти решение своей проблемы.

Код ServerTCP 

class ServerTCP
{
public:
   ServerTCP(boost::asio::io_service& A_ioService, unsigned short A_uPortNumber = 13)
      : m_tcpAcceptor(A_ioService, tcp::endpoint(tcp::v4(), A_uPortNumber)), m_ioService (A_ioService)
   {
      start();
   }
private:

   void start()
   {
      ClientSessionPtr spClient(new ClientSession(m_tcpAcceptor.io_service(), m_connectedClients));

      m_tcpAcceptor.async_accept(spClient->getSocket(), 
                                 boost::bind(&ServerTCP::handleAccept, this, spClient, 
                                 boost::asio::placeholders::error));

   }
   void handleAccept(ClientSessionPtr A_spNewClient,  const boost::system::error_code& A_nError)
   {
      if ( !A_nError )
      {
         A_spNewClient->start();
         start();
      }
   }



   boost::asio::io_service& m_ioService;
   tcp::acceptor            m_tcpAcceptor;
   Clients                  m_connectedClients;
};

Основная функция: 

   try
   {
      boost::asio::io_service ioService;

      ServerTCP server(ioService);
      ioService.run();  
   }
   catch (std::exception& e)
   {
      std::cerr << "Exception: " << e.what() << "\n";
   }

Привет Сэм.Спасибо за ответ.Не могли бы вы быть так добры и показать мне какой-нибудь фрагмент кода или несколько ссылок на примеры, связанные с этой проблемой?Возможно, я не правильно понимаю "... однопоточный сервер ..."

На самом деле в "консоли", где я хочу управлять серверными операциями, мне нужно smt, как показано ниже: 

main()

cout << "Options: q - close server, s - show clients";
while(1)
{
  char key = _getch();
  switch( key )
  {
      case 'q':
         closeServer();
      break
      case 's':
         showClients();
      break
  } 
}

Ответы [ 2 ]

3 голосов
/ 06 марта 2011

Проблема в том, как я могу прикрепить (или пишите) консоль, которая может звонить выше Функциональные возможности. Эта консоль должна быть клиентом? Должен ли я запустить эту консоль клиент как отдельный поток?

Вам не нужен отдельный поток, используйте posix::stream_descriptor и назначьте STDIN_FILENO. Используйте async_read и обрабатывайте запросы в обработчиках чтения. 

#include <boost/asio.hpp>

#include <boost/bind.hpp>
#include <boost/enable_shared_from_this.hpp>
#include <boost/shared_ptr.hpp>

#include <iostream>

using namespace boost::asio;

class Input : public boost::enable_shared_from_this<Input>
{
public:
    typedef boost::shared_ptr<Input> Ptr;

public:
    static void create(
            io_service& io_service
            )
    {
        Ptr input(
                new Input( io_service )
                );
        input->read();
    }

private:
    explicit Input(
            io_service& io_service
         ) :
        _input( io_service )
    {
        _input.assign( STDIN_FILENO );
    }

    void read()
    {
        async_read(
                _input,
                boost::asio::buffer( &_command, sizeof(_command) ),
                boost::bind(
                    &Input::read_handler,
                    shared_from_this(),
                    placeholders::error,
                    placeholders::bytes_transferred
                    )
                );
    }

    void read_handler(
            const boost::system::error_code& error,
            size_t bytes_transferred
            )
    {
        if ( error ) {
            std::cerr << "read error: " << boost::system::system_error(error).what() << std::endl;
            return;
        }

        if ( _command != '\n' ) {
            std::cout << "command: " << _command << std::endl;
        }

        this->read();
    }

private:
    posix::stream_descriptor _input;
    char _command;
};

int
main()
{
    io_service io_service;
    Input::create( io_service );
    io_service.run();
}
1 голос
/ 06 марта 2011

Если я правильно понимаю ОП, он / она хочет запустить асинхронный TCP-сервер, который управляется через консоль, т.е. консоль используется в качестве пользовательского интерфейса. В этом случае вам не нужно отдельное клиентское приложение для запроса к серверу подключенных клиентов и т. Д.:

  • Вам нужно создать поток, который каким-то образом вызывает метод io_service :: run. В настоящее время вы звоните из главного. Поскольку ваш сервер, вероятно, будет ограничен в основном, вам нужно сделать что-то вроде передачи ссылки на сервер в новый поток. Io_service может, например, быть членом класса сервера (если только у вашего приложения нет других требований, в этом случае сервер и io_service передаются в новый поток).
  • добавьте соответствующие методы, такие как showClients, closeServer и т. Д., В класс вашего сервера
  • убедитесь, что эти вызовы, запускаемые через консоль, являются поточно-ориентированными
  • в вашем методе closeServer вы можете, например, вызвать io_service :: stop, что приведет к окончанию работы сервера.
...