//-- 服务端 --
//-- bool create();
int m_sock = -1;
//domain:说明我们网络程序所在的主机采用的通讯协族(AF_UNIX和AF_INET等). AF_UNIX只能够用于单一的Unix系统进程间通信,而AF_INET是针对Internet的,因而可以允许在远程主机之间通信
//type:我们网络程序所采用的通讯协议(SOCK_STREAM,SOCK_DGRAM等) SOCK_STREAM表明我们用的是TCP协议,这样会提供按顺序的,可靠,双向,面向连接的比特流. SOCK_DGRAM 表明我们用的是UDP协议,这样只会提供定长的,不可靠,无连接的通信.
//protocol:由于我们指定了type,所以这个地方我们一般只要用0来代替就可以了
//socket为网络通讯做基本的准备.成功时返回文件描述符,失败时返回-1,看errno可知道出错的详细情况
m_sock = socket(AF_INET, SOCK_STREAM, 0); //!!## 实测=0x05
DEBUG_LOG("m_sock=%d\n", m_sock);
if (m_sock == -1)
return -1;
int on = 1;
if (::setsockopt(m_sock, SOL_SOCKET, SO_REUSEADDR, (const char*) &on,
sizeof(on)) == -1)
return -2;
DEBUG_LOG("::setsockopt() done.\n");
//-- bool bind(const int port);
memset(&m_addr, 0, sizeof(m_addr));
m_addr.sin_family = AF_INET;
m_addr.sin_addr.s_addr = INADDR_ANY;
m_addr.sin_port = htons(port);
//sockfd:是由socket调用返回的文件描述符.
//addrlen:是sockaddr结构的长度.
//my_addr:是一个指向sockaddr的指针.
//不过由于系统的兼容性,我们一般不用这个头文件,而使用另外一个结构(struct sockaddr_in) 来代替
//成功是返回0,失败的情况和socket一样(##Gophern 理解：看errno可知道出错的详细情况)
if (::bind(m_sock, (struct sockaddr *) &m_addr, sizeof(m_addr)) != 0) //== -1)
return -3
//-- bool listen() const;
//listen函数将bind的文件描述符变为监听套接字.返回的情况和bind一样.
//sockfd:是bind后的文件描述符.
//backlog:设置请求排队的最大长度.当有多个客户端程序和服务端相连时, 使用这个表示可以介绍的排队长度. listen函数将bind的文件描述符变为监听套接字.返回的情况和bind一样.
if (::listen(m_sock, MAXCONNECTIONS) != 0)
return -4;
while (true) {
//-- bool accept(Socket&) const;
int addr_length = sizeof(m_addr);
//sockfd:是listen后的文件描述符.
//addr,addrlen是用来给客户端的程序填写的,服务器端只要传递指针就可以了. bind,listen和accept是服务器端用的函数,accept调用时,服务器端的程序会一直阻塞到有一个客户程序发出了连接. accept成功时返回最后的服务器端的文件描述符,这个时候服务器端可以向该描述符写信息了. 失败时返回-1
int newSocket = ::accept(m_sock, (sockaddr *) &m_addr, (socklen_t *) &addr_length); //!!## 实测=0x06
if (newSocket <= 0) {
DEBUG_LOG("::accept() failed, newSocket = %d\n", newSocket);
return -1001;
}
try {
while (true) {
//std::string data;
//new_sock >> data;
//输入 Socket::recv(std::string &s)
const int MAXRECV = 500;
char buf[MAXRECV + 1];
memset(buf, 0, MAXRECV + 1);
//!!##Gophern: 调用::recv()时，回阻塞，在telnet输入一行敲回车时返回
//!!## 若Telnet输入的内容超过MAXRECV，则下次（循环到此处时）不会阻塞，而是继续读入剩下的字节。
int status = ::recv(m_sock, buf, MAXRECV, 0); //!!## 输入"123"+回车 => bytesNum=5 | "123\\r\\n"
if (status == -1) {
std::cout << "status == -1 errno == " << errno
<< " in Socket::recv\n";
return 0;
} else if (status == 0) {
//这是Telnet客户端Close Connection的时候发生的
return 0;
} else {
s = buf;
return status;
}
//new_sock << data; //反馈客户端回显
//输出 Socket::send(std::string &s)
int status = ::send(m_sock, s.c_str(), s.size(), MSG_NOSIGNAL);
if (status == -1)
return -2001;
}
} catch (SocketException &e) {
std::cout << "Exception was caught:" << e.description()
<< "\nExiting.\n";
}
}
//-- 客户端 --
//-- Socket::create()
int m_sock = -1;
m_sock = socket ( AF_INET, SOCK_STREAM, 0 );
Debug.Assert(m_sock != -1);
int on = 1;
Debug.Assert( setsockopt ( m_sock, SOL_SOCKET, SO_REUSEADDR, ( const char* ) &on, sizeof ( on ) ) != -1 );
//-- Socket::connect ( host, port )
memset(&m_addr, 0, sizeof(m_addr));
m_addr.sin_family = AF_INET;
m_addr.sin_port = htons ( port );
int status = inet_pton ( AF_INET, host.c_str(), &m_addr.sin_addr );
Debug.Assert( errno != EAFNOSUPPORT );
//int connect(int sockfd, struct sockaddr * serv_addr,int addrlen)
//sockfd:socket返回的文件描述符.
//serv_addr:储存了服务器端的连接信息.其中sin_add是服务端的地址
//addrlen:serv_addr的长度
//connect函数是客户端用来同服务端连接的.成功时返回0,sockfd是同服务端通讯的文件描述符失败时返回-1
status = ::connect ( m_sock, ( sockaddr * ) &m_addr, sizeof ( m_addr ) );
Debug.Assert(status == 0);
