server.h

ACE的通信程序

#pragma once

#ifndef __SERVER_H_
#define __SERVER_H_

#include "ace/Svc_Handler.h"
#include "ace/SOCK_Stream.h"
#include "ace/SOCK_Dgram.h"
#include "ace/Synch.h"
#include "ace/Thread_Manager.h"
#include "ace/Task.h"
#include "ace/Message_Block.h"

namespace ACE_Server
{
	static const size_t SERVER_THREAD_POOL_SIZE = 5;   //进行数据接收的线程池大小
	static const size_t TASK_THREAD_POOL_SIZE = 5; //进行数据处理的线程池大小
	static const size_t BUFFER_SIZE = 4096;   //数据缓冲区大小
	static const size_t SERVER_PORT_NUM = 10101;   //服务器的通信端口号

	class Server: public ACE_Task_Base
	{
	public:
		virtual int svc(void);
	};

	class Task_Worker: public ACE_Task<ACE_MT_SYNCH>
	{
	public:
		virtual int svc(void);
	private:
		void process_task(ACE_Message_Block *mb);
	};

	class Task_Manager: public ACE_Task<ACE_MT_SYNCH>
	{
	public:
		virtual int svc(void);
	};

	class Request_Handler: public ACE_Event_Handler
	{
	public:
		Request_Handler(const ACE_INET_Addr &local_addr);
		virtual ACE_HANDLE get_handle (void) const;
		virtual int handle_close (ACE_HANDLE handle,ACE_Reactor_Mask);
		virtual int handle_timeout (const ACE_Time_Value & tv, const void *arg = 0);
	protected:
		virtual int handle_input(ACE_HANDLE fd = ACE_INVALID_HANDLE);
	private:
		static Task_Manager task_mgr;
		ACE_SOCK_Dgram endpoint_;
	};
}
#endif