ACE Task Framework 16 – 기본 샘플3

2013/06/14 by admin

ACE_Message_Queue는 메세지가 입력되면 ACE_Reactor로부터 Notify 이벤트를 받을 수 있습니다.

MQ_Handler.h
#pragma once
#include <ace/Event_Handler.h>
#include <ace/Reactor_Notification_Strategy.h>

#include <ace/Synch.h>
#include <ace/Message_Queue.h>

class MQ_Handler:
   public ACE_Event_Handler,
   public ACE_Reactor_Notification_Strategy,
   public ACE_Message_Queue<ACE_MT_SYNCH>
{
public:
   explicit MQ_Handler(ACE_Reactor* reactor);
    ~MQ_Handler(void);

   virtual int handle_output (ACE_HANDLE fd = ACE_INVALID_HANDLE);
};

MQ_Handler.cpp
#include "MQ_Handler.h"

#include <iostream>

MQ_Handler::MQ_Handler(ACE_Reactor* reactor)
    :
   ACE_Event_Handler(reactor),
   ACE_Reactor_Notification_Strategy(reactor,this,ACE_Event_Handler::WRITE_MASK),
   ACE_Message_Queue<ACE_MT_SYNCH>(ACE_Message_Queue::DEFAULT_HWM, ACE_Message_Queue::DEFAULT_LWM,this)
{
}

MQ_Handler::~MQ_Handler(void)
{
}

int
MQ_Handler::handle_output (ACE_HANDLE fd /*= ACE_INVALID_HANDLE*/){
    std::cout<<std::endl<< "--Start--";

   ACE_Message_Block* mdata;
   if( -1==this->dequeue_head(mdata) ) return 0;

    std::cout<< std::endl <<"msg data:"<< (const char*)mdata->rd_ptr();
    std::cout<<std::endl<< "--End--";
    mdata->release();
   return 0;
}

MQ1.cpp
// MQ1.cpp : Defines the entry point for the console application.
//

#include "stdafx.h"

#include <ace/ACE.h>
#include "MQ_Handler.h"
#include <ace/Thread_Manager.h>
#include <iostream>
#include <string>
#include <ace/Reactor.h>
#include <ace/OS.h>

ACE_THR_FUNC_RETURN fn (void * obj){
   MQ_Handler* mq =(MQ_Handler*) obj;
    std::string cmd;

   while(true){
       std::cout<<std::endl<<"전송할 메세지를 입력하세요. 종료시 exit를 입력하세요."<<std::endl;
       std::getline( std::cin, cmd );
      if("exit"==cmd){
         ACE_Reactor::instance()->end_reactor_event_loop();
         break;
      }

      ACE_Message_Block* data = new ACE_Message_Block( cmd.size()+1);
       data->copy( cmd.c_str() );
       mq->enqueue_tail( data );

       ACE_OS::sleep(1);
   }
   return 0;
}

int _tmain(int argc, _TCHAR* argv[])
{
    ACE::init();
   {
      ACE_Reactor* reactor = ACE_Reactor::instance();
      MQ_Handler mq( reactor);

       reactor->register_handler( &mq, ACE_Event_Handler::NULL_MASK);

      ACE_Thread_Manager tm;
       tm.spawn( fn,&mq);

       reactor->run_reactor_event_loop();

       tm.wait();

       system("pause");

   }
    ACE::fini();

   return 0;
}

- 목록:

라이브러리 포팅하기
간단히 Echo 서버 만들어보기
간단히 Echo 클라이언트 만들기
ACE_Select_Reactor에 대한 이해
ACE_TP_Reactor 이해 – Leader/Followers 패턴
ACE_WMFO_Reactor 이해
Service Configurator Framework 1 – 개요
Service Configurator Framework 2 – ACE_Service_Config 클래스 이해
Service Configurator Framework 3 – 동적/정적 서비스
Service Configurator Framework 4 – 서비스를 등록하는 과정
Service Configurator Framework 5 – ACE_Service_Repository 클래스
ACE Task Framework 1 – 개요
ACE Task Framework 2 – Active Object 패턴 이해
ACE Task Framework 3 – Half-Sync/Half-Async 패턴 이해
ACE Task Framework 4 – ACE_Task_Base 클래스 이해
ACE Task Framework 5 – ACE_Task 클래스 이해
ACE Task Framework 6 – ACE_Message_Block 클래스 이해 1
ACE Task Framework 7 – ACE_Message_Block 클래스 이해 2
ACE Task Framework 8 – ACE_Message_Queue 이해 1
ACE Task Framework 9 – ACE_Message_Queue 이해 2
ACE Task Framework 10 – ACE_Message_Queue 이해 3
ACE Task Framework 11 – ACE_Thread_Manager 클래스 이해 1
ACE Task Framework 12 – ACE_Thread_Manager 클래스 이해 2
ACE Task Framework 13 – ACE_Thread_Manager 클래스 이해 3
ACE Task Framework 14 – 기본 샘플1
ACE Task Framework 15 – 기본 샘플2
ACE Task Framework 16 – 기본 샘플3
ACE Acceptor-Connector framework 1 – ACE_Svc_Handler 이해1
ACE Acceptor-Connector framework 2 – ACE_Svc_Handler 이해2
ACE Acceptor-Connector framework 3 – ACE_Acceptor 클래스 이해
ACE Acceptor-Connector framework 4 – ACE_Connector 클래스 이해
ACE Proactor Framework 1 – 비동기과 서버 모델
ACE Proactor Framework 2 – 비동기 IO 이해하기
ACE Proactor Framework 3 – 비동기 IO 기술 요소
ACE Proactor Framework 4 – Echo 서버 만들기
ACE Proactor Framework 5 – Echo 클라이언트 만들기
ACE Proactor Framework 6 – UDP 사용하기
ACE Proactor Framework 7 – serial port 사용하기
ACE Proactor Framework 8 – Review
ACE Proactor Framework 9 – Acceptor-Connector 예제 1
ACE Proactor Framework 10 – Acceptor-Connector 예제 2