1

Есть сервер, который создаёт отдельный поток для каждого нового клиента

while ((client_socket = accept(server_socket, (sockaddr*)&client_info, &client_addr_size)))
{
    nclients++;
    HOSTENT *hst;
    hst = gethostbyaddr((char*)&client_info.sin_addr.S_un.S_addr, 4, AF_INET);
    printf("+%s [%s] new connect!\n", (hst) ? hst->h_name : "", inet_ntoa(client_info.sin_addr));
    PRINTUSERS;
    DWORD thID;
    CreateThread(NULL, NULL, SexToClient, &client_socket, NULL, &thID);
}

Сама функция потока каждые n секунд отправляет клиенту определённые сообщения.(Все потоки делают это не одновременно) Не могу понять , как отправить сообщение всем клиентам одновременно. (Уверен, что я вообще запутался,и нужно идти совсем иным путём). Собственно вопрос, как это реализовать?

1
  • 1
    Типичный broadcast это udp, а не tcp, который очевидно Вы (судя по accept) используете. Т.е. можно кинуть пакет с broadcast IP адресом, который будет принят всеми компьютерами LAN у которых кто-то слушает заданный в этом пакете порт в протоколе udp.
    – avp
    5 апр 2016 в 21:01

2 ответа 2

1

Вижу два способа решения этой задачи.

  1. Передача широковещательного (broadcast) сообщения. Для передачи таких сообщений используется протокол UDP, а не TCP. Тогда в клиентах нужно будет добавить прием и обработку UDP-дейтаграмм.
  2. Передача необходимых данных в рамках основного обмена. В этом случае нужно отправлять сообщение всем запущенным на сервере потокам, по приему которого производится передача данных клиентам.
-1

Можно попробовать делегат и стандартный коллбэк. Вот пример

#include <assert.h>

//  Контейнер для хранения до 2-х аргументов.
struct NIL {};
class IArguments { public: virtual ~IArguments() {} };
template< class T1 = NIL, class T2 = NIL >
  class Arguments : public IArguments
{
  public: Arguments() {}
  public: Arguments( T1 i_arg1 ) :
    arg1( i_arg1 ) {}
  public: Arguments( T1 i_arg1, T2 i_arg2 ) :
    arg1( i_arg1 ), arg2( i_arg2 ) {}
  public: T1 arg1; T2 arg2;
};

//  Контейнер для хранения указателя на метод.
class IContainer { public: virtual void Call( IArguments* ) = 0; };
template< class T, class M > class Container : public IContainer {};

//  Специализация для метода без аргументов.
template< class T >
  class Container< T, void (T::*)(void) > : public IContainer
{
  typedef void (T::*M)(void);
  public: Container( T* c, M m ) : m_class( c ), m_method( m ) {}
  private: T* m_class; M m_method;
  public: void Call( IArguments* i_args )
  {
    (m_class->*m_method)();
  }
};

//  Специализация для метода с одним аргументом.
template< class T, class A1 >
  class Container< T, void (T::*)(A1) > : public IContainer
{
  typedef void (T::*M)(A1);
  typedef Arguments<A1> A;
  public: Container( T* c, M m ) : m_class( c ), m_method( m ) {}
  private: T* m_class; M m_method;
  public: void Call( IArguments* i_args )
  {
    A* a = dynamic_cast< A* >( i_args );
    assert( a );
    if( a ) (m_class->*m_method)( a->arg1 );
  }
};

//  Специализация для метода с двумя аргументами
template< class T, class A1, class A2 >
  class Container< T, void (T::*)(A1,A2) > : public IContainer
{
  typedef void (T::*M)(A1,A2);
  typedef Arguments<A1,A2> A;
  public: Container( T* c, M m ) : m_class( c ), m_method( m ) {}
  private: T* m_class; M m_method;
  public: void Call( IArguments* i_args )
  {
    A* a = dynamic_cast< A* >( i_args );
    assert( a );
    if( a ) (m_class->*m_method)( a->arg1, a->arg2 );
  }
};

//  Собственно делегат.
class Delegate
{
public:

  Delegate() : m_container( 0 ) {}
  ~Delegate() { if( m_container ) delete m_container; }

  template< class T, class U > void Connect( T* i_class, U i_method )
  {
    if( m_container ) delete m_container;
    m_container = new Container< T, U >( i_class, i_method );
  }

  void operator()()
  {
    m_container->Call( & Arguments<>() );
  }

  template< class T1 > void operator()( T1 i_arg1 )
  {
    m_container->Call( & Arguments< T1 >( i_arg1 ) );
  }

  template< class T1, class T2 > void operator()( T1 i_arg1, T2 i_arg2 )
  {
    m_container->Call( & Arguments< T1, T2 >( i_arg1, i_arg2 ) );
  }

private:
  IContainer* m_container;
};

class Victim { public: void Foo() {} void Bar( int ) {} };

int main()
{
  Victim test_class;
  Delegate test_delegate;
  test_delegate.Connect( & test_class, & Victim::Foo );
  test_delegate();
  test_delegate.Connect( & test_class, & Victim::Bar );
  test_delegate( 10 );
  return 0;
}
1
  • Что-то у меня ощущение, что это ответ не на тот вопрос...
    – Harry
    6 апр 2016 в 3:23

Ваш ответ

Нажимая на кнопку «Отправить ответ», вы соглашаетесь с нашими пользовательским соглашением, политикой конфиденциальности и политикой о куки

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.