概述:

    传输控制协议TCP(Transmission Control Protocol):TCP提供可靠的、面向连接的运输服务,用于高可靠性数据的传输。TCP协议的可靠性是指保证每个tcp报文能按照发送顺序到达客户端。 

Tcp通信过程一般为如下步骤:

    服务器绑定端口,等

待客户端连接。

    客户端通过服务器的ip和服务器绑定的端口连接服务器。

    服务器和客户端通过网络建立一条数据通路,通过这条数据通路进行数据交互。

常用API:

1. ACE_INET_Addr类。

 ACE"地址"类ACE_Addr的子类,表示TCP/IP和UDP/IP的地址。它通常包含机器的ip和端口信息,通过它可以定位到所通信的进程。

定义方式:

ACE_INET_Addr addInfo(3000,"192.168.1.100"); 

常用方法:

get_host_name    获取主机名

get_ip_address    获取ip地址

get_port_number    获取端口号

2. ACE_SOCK_Acceptor类。

服务期端使用,用于绑定端口和被动地接受连接。

常用方法:

open 绑定端口

accept建立和客户段的连接

3.  ACE_SOCK_Connector类。

客户端使用,用于主动的建立和服务器的连接。

常用方法:

connect()    建立和服务期的连接。

4. ACE_SOCK_Stream类。

客户端和服务器都使用,表示客户段和服务器之间的数据通路。

常用方法:

send ()    发送数据

recv ()    接收数据

close()    关闭连接(实际上就是断开了socket连接)。

代码示例:

下面例子演示了如何如何用ACE创建TCP通信的Server端。

#define WIN32
#include <iostream>
#include <string>
#include "ace/SOCK_Acceptor.h"  //服务器端使用,用于绑定端口和被动的接受连接
#include "ace/SOCK_Stream.h"	//客户端服务器都使用,表示客户端和服务器之间的数据通路,包括:收发消息send()/recv() 和关闭连接close()
#include "ace/INET_Addr.h"		//ACE_Addr的子类,表示TCP/IP和UPD/IP的地址,它通常包含机器的ip和端口信息,通过它可以定位到所通信的进程。
								//常用方法包括: get_host_name 获取主机名  、  get_ip_address 获取ip地址  、 get_port_number 获取端口号
#include "ace/OS.h"

using namespace std;


int main(int, char**)
{
	ACE_INET_Addr port_to_listen(3000);		//绑定的端口
	ACE_SOCK_Acceptor acceptor;

	if (acceptor.open(port_to_listen, 1) == -1)//绑定端口
	{
		cout << "bind port failed!" << endl;
		return -1;
	}

	while (true)
	{
		ACE_SOCK_Stream peer;		//和客户端的数据通路
		ACE_Time_Value timeout(10, 0);

		if (acceptor.accept(peer) != -1)	//建立连接
		{
			cout << "client connect!" << endl;
			char buffer[1024];
			ssize_t bytes_received;

			ACE_INET_Addr raddr;
			peer.get_local_addr(raddr);
			cout << "local port\t" << raddr.get_host_name() << "\t" << raddr.get_port_number() << endl;

			while ((bytes_received = peer.recv(buffer,sizeof(buffer)))!=-1)
			{
				peer.send(buffer, bytes_received);
			}

			peer.close();
		}
	}


	return 0;
}

这个例子实现的功能很简单,服务器端绑定3000号端口,等待一个客户端的连接,然后将从客户端读取的数据再次转发给客户端,也就是实现了一个EchoServer的功能。

相应的客户端程序也比较简单,代码如下:

#include <ace/SOCK_Stream.h>
#include <ace/SOCK_Connector.h> 
#include <ace/INET_Addr.h>
#include <ace/Time_Value.h> 

#include <string>
#include <iostream>
using namespace std;

int main(int argc, char *argv[]) 
{
    ACE_INET_Addr addr(3000,"127.0.0.1");

    ACE_SOCK_Connector connector;    
    ACE_Time_Value timeout(5,0);
    ACE_SOCK_Stream peer;

    if(connector.connect(peer,addr,&timeout) != 0)
    {
        cout<<"connection failed !"<<endl;
        return 1;
    }
    cout<<"conneced !"<<endl;

    string s="hello world";
    peer.send(s.c_str(),s.length());    //发送数据
    cout<<endl<<"send:\t"<<s<<endl;

    ssize_t bc=0;            //接收的字节数

    char buf[1024];
    bc=peer.recv(buf,1024,&timeout);    //接收数据
    if(bc>=0)
    {
        buf[bc]='\0';
        cout<<endl<<"rev:\t"<<buf<<endl;
    }
    peer.close();

    return 0; 
}


下表给出了服务器端和客户端的传输过程的比较:


                         操作                        客户端                       服务器端
                        初始化不需要调用acceptor.open()绑定端口
                       建立连接调用connector.connect()方法调用acceptor.accept()方法
                       传输数据发送:调用peer.recv()方法
接收:调用peer.send()方法

                       关闭连接调用peer.close()方法