//Example 1
#include "ace/SOCK_Acceptor.h"
#include "ace/SOCK_Stream.h"
#define SIZE_DATA 18
#define SIZE_BUF 1024

class Server{

public:
Server (int port):
 server_addr_(port),peer_acceptor_(server_addr_){
 data_buf_= new char[SIZE_BUF];
 }

//Handle the connection once it has been established.
//Here the connection is handled by reading SIZE_DATA amount of data
//from the remote and then closing the connection
//stream down.
int handle_connection(){
  // Read data from client
 if(new_stream_.recv_n (data_buf_, SIZE_DATA, 0)==-1)
  ACE_ERROR ((LM_ERROR, "%p\n", "Error in recv"));
 

 ACE_DEBUG((LM_DEBUG,"Server recieved %s \n",data_buf_));
 
 // Close new endpoint
 if (new_stream_.close () == -1)
  ACE_ERROR ((LM_ERROR, "%p\n", "close"));
 return 0;
}
//Use the acceptor component peer_acceptor_ to accept the connection
//into the underlying stream new_stream_. After the connection has been
//established call the handle_connenction() method.
int accept_connections (){
 if (peer_acceptor_.get_local_addr (server_addr_) == -1)
  ACE_ERROR_RETURN ((LM_ERROR,"%p\n","Error in get_local_addr"),1);

 ACE_DEBUG ((LM_DEBUG,"Starting server at port %d\n",
  server_addr_.get_port_number ()));
 

 // Performs the iterative server activities.
 while(1){
  ACE_Time_Value timeout (ACE_DEFAULT_TIMEOUT);
  if (peer_acceptor_.accept
    (new_stream_, &client_addr_, &timeout)== -1){
   ACE_ERROR ((LM_ERROR, "%p\n", "accept"));
   continue;
   }
  else
   ACE_DEBUG((LM_DEBUG,
   "Connection established with remote %s:%d\n",
   client_addr_.get_host_name(),client_addr_.get_port_number()));
   //Handle the connection
   handle_connection();
  }
 }
 
 

private:
 char *data_buf_;
 ACE_INET_Addr server_addr_;
 ACE_INET_Addr client_addr_;
 ACE_SOCK_Acceptor peer_acceptor_;
 ACE_SOCK_Stream new_stream_;
 ACE_HANDLE newhandle;
};

int main (int argc, char *argv[]){
 if(argc<2){
  ACE_ERROR((LM_ERROR,"Usage egX <port_num>"));
  ACE_OS::exit(1);
  }
 Server server(ACE_OS::atoi(argv[1]));
 server.accept_connections();
}

 Next Example