侵刪
轉載自 http://blog.csdn.net/amaowolf/article/details/8008575
轉載自 http://www.cnblogs.com/jianqiang2010/archive/2010/08/20/1804598.html
轉載自 吳秦http://www.cnblogs.com/skynet/archive/2010/12/12/1903949.html
轉載自http://blog.csdn.net/lgp88/article/details/7176509
轉載自http://www.cnblogs.com/ccsccs/articles/4224253.html
轉載自http://blog.csdn.net/piaojun_pj/article/details/5991968/
轉載自http://www.it.uom.gr/teaching/distrubutedSite/dsIdaLiu/labs/lab2_1/sockets.html
1、 網絡中進程之間如何通信
首要解決的問題是如何唯一標識一個進程，在本地可以通過進程PID來唯一標識一個進程，但是在網絡中這是行不通的。其實TCP/IP協議族已經幫我們解決了這個問題，網絡層的ip地址可以唯一標識網絡中的主機，而傳輸層的協議+端口可以唯一標識主機中的應用程序（進程）。這樣利用三元組（ip地址，協議，端口）就可以標識網絡的進程了，網絡中的進程通信就可以利用這個標志與其它進程進行交互。
2、 Socket是什么
socket起源於Unix，而Unix/Linux基本哲學之一就是“一切皆文件”，都可以用“打開open –> 讀寫write/read –> 關閉close”模式來操作。我的理解就是Socket就是該模式的一個實現，socket即是一種特殊的文件，一些socket函數就是對其進行的操作（讀/寫IO、打開、關閉）。
說白了Socket是應用層與TCP/IP協議族通信的中間軟件抽象層，它是一組接口。在設計模式中，Socket其實就是一個門面模式，它把復雜的TCP/IP協議族隱藏在Socket接口后面，對用戶來說，一組簡單的接口就是全部，讓Socket去組織數據，以符合指定的協議。
3、 Socket的基本操作
3.1、socket()函數
int socket(int domain, int type, int protocol);socket函數對應於普通文件的打開操作。普通文件的打開操作返回一個文件描述字，而socket()用於創建一個socket描述符（socket descriptor），它唯一標識一個socket。這個socket描述字跟文件描述字一樣，后續的操作都有用到它，把它作為參數，通過它來進行一些讀寫操作。
正如可以給fopen的傳入不同參數值，以打開不同的文件。創建socket的時候，也可以指定不同的參數創建不同的socket描述符，socket函數的三個參數分別為：
•domain：即協議域，又稱為協議族（family）。常用的協議族有，AF_INET（IPv4)、AF_INET6(IPv6)、AF_LOCAL（或稱AF_UNIX，Unix域socket）、AF_ROUTE等等。協議族決定了socket的地址類型，在通信中必須采用對應的地址，如AF_INET決定了要用ipv4地址（32位的）與端口號（16位的）的組合、AF_UNIX決定了要用一個絕對路徑名作為地址。
•type：指定socket類型。常用的socket類型有，SOCK_STREAM（流式套接字）、SOCK_DGRAM（數據報式套接字）、SOCK_RAW、SOCK_PACKET、SOCK_SEQPACKET等等
•protocol：就是指定協議。常用的協議有，IPPROTO_TCP、PPTOTO_UDP、IPPROTO_SCTP、IPPROTO_TIPC等，它們分別對應TCP傳輸協議、UDP傳輸協議、STCP傳輸協議、TIPC傳輸協議。
注意：並不是上面的type和protocol可以隨意組合的，如SOCK_STREAM不可以跟IPPROTO_UDP組合。當protocol為0時，會自動選擇type類型對應的默認協議。
3.1.1、 命名socket
SOCK_STREAM式套接字的通信雙方均需要具有地址，其中服務器端的地址需要明確指定，ipv4的指定方法是使用 struct sockaddr_in類型的變量。
struct sockaddr_in { sa_family_t sin_family; /* address family: AF_INET */ in_port_t sin_port; /* port in network byte order */ struct in_addr sin_addr; /* internet address */ }; /* Internet address. */ struct in_addr { uint32_t s_addr; /* address in network byte order */ };struct sockaddr_in servaddr; memset(&servaddr, 0, sizeof(servaddr)); servaddr.sin_family = AF_INET; servaddr.sin_addr.s_addr = htonl(INADDR_ANY);//IP地址設置成INADDR_ANY,讓系統自動獲取本機的IP地址。 servaddr.sin_port = htons(DEFAULT_PORT);//設置的端口INADDR_ANY就是指定地址為0.0.0.0的地址，這個地址事實上表示不確定地址，或“所有地址”、“任意地址”。也就是表示本機的所有IP，因為有些機子不止一塊網卡，多網卡的情況下，這個就表示所有網卡ip地址的意思。客戶端connect時，不能使用INADDR_ANY選項。必須指明要連接哪個服務器IP。
htons將主機的無符號短整形數轉換成網絡字節順序
htonl將主機的無符號長整形數轉換成網絡字節順序
網絡字節序與主機字節序：
主機字節序就是我們平常說的大端和小端模式：不同的CPU有不同的字節序類型，這些字節序是指整數在內存中保存的順序，這個叫做主機序。引用標准的Big-Endian和Little-Endian的定義如下：
a) Little-Endian就是低位字節排放在內存的低地址端，高位字節排放在內存的高地址端。
b) Big-Endian就是高位字節排放在內存的低地址端，低位字節排放在內存的高地址端。
網絡字節序：4個字節的32 bit值以下面的次序傳輸：首先是0～7bit，其次8～15bit，然后16～23bit，最后是24~31bit。這種傳輸次序稱作大端字節序。由於TCP/IP首部中所有的二進制整數在網絡中傳輸時都要求以這種次序，因此它又稱作網絡字節序。字節序，顧名思義字節的順序，就是大於一個字節類型的數據在內存中的存放順序，一個字節的數據沒有順序的問題了。
在將一個地址綁定到socket的時候，請先將主機字節序轉換成為網絡字節序，而不要假定主機字節序跟網絡字節序一樣使用的是Big-Endian。謹記對主機字節序不要做任何假定，務必將其轉化為網絡字節序再賦給socket。
當我們調用socket創建一個socket時，返回的socket描述字它存在於協議族（address family，AF_XXX）空間中，但沒有一個具體的地址。如果想要給它賦值一個地址，就必須調用bind()函數，否則就當調用connect()、listen()時系統會自動隨機分配一個端口。
3.2、bind()函數
bind()函數把一個地址族中的特定地址賦給socket。例如對應AF_INET、AF_INET6就是把一個ipv4或ipv6地址和端口號組合賦給socket。
int bind(int sockfd, const struct sockaddr *addr, socklen_t addrlen);函數的三個參數分別為：
•sockfd：即socket描述字，它是通過socket()函數創建了，唯一標識一個socket。bind()函數就是將給這個描述字綁定一個名字。
•addr：一個const struct sockaddr *指針，指向要綁定給sockfd的協議地址。
struct sockaddr{ sa_family_t sin_family; //地址族（Address Family），也就是地址類型 char sa_data[14]; //IP地址和端口號 };sockaddr 是一種通用的結構體，可以用來保存多種類型的IP地址和端口號。要想給 sa_data 賦值，必須同時指明IP地址和端口號，例如”127.0.0.1:80“，但沒有相關函數將這個字符串轉換成需要的形式，也就很難給 sockaddr 類型的變量賦值。正是由於通用結構體 sockaddr 使用不便，才針對不同的地址類型定義了不同的結構體。 如ipv6對應的是：
struct sockaddr_in6 { sa_family_t sin6_family; /* AF_INET6 */ in_port_t sin6_port; /* port number */ uint32_t sin6_flowinfo; /* IPv6 flow information */ struct in6_addr sin6_addr; /* IPv6 address */ uint32_t sin6_scope_id; /* Scope ID (new in 2.4) */ }; struct in6_addr { unsigned char s6_addr[16]; /* IPv6 address */ };Unix域對應的是：
#define UNIX_PATH_MAX 108 struct sockaddr_un { sa_family_t sun_family; /* AF_UNIX */ char sun_path[UNIX_PATH_MAX]; /* pathname */ };•addrlen：對應的是地址的長度。
通常服務器在啟動的時候都會綁定一個眾所周知的地址（如ip地址+端口號），用於提供服務，客戶就可以通過它來接連服務器；而客戶端就不用指定，有系統自動分配一個端口號和自身的ip地址組合。這就是為什么通常服務器端在listen之前會調用bind()，而客戶端就不會調用，而是在connect()時由系統隨機生成一個。
3.3 listen()、connect()函數
如果作為一個服務器，在調用socket()、bind()之后就會調用listen()來監聽這個socket，如果客戶端這時調用connect()發出連接請求，服務器端就會接收到這個請求。
int listen(int sockfd, int backlog); int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);listen函數的第一個參數即為要監聽的socket描述字，第二個參數為相應socket可以排隊的最大連接個數。socket()函數創建的socket默認是一個主動類型的，listen函數將socket變為被動類型的，等待客戶的連接請求。
connect函數的第一個參數即為客戶端的socket描述字，第二參數為服務器的socket地址，第三個參數為socket地址的長度。客戶端通過調用connect函數來建立與TCP服務器的連接。
3.4 accept()函數
TCP服務器端依次調用socket()、bind()、listen()之后，就會監聽指定的socket地址了。TCP客戶端依次調用socket()、connect()之后就向TCP服務器發送了一個連接請求。TCP服務器監聽到這個請求之后，就會調用accept()函數取接收請求，這樣連接就建立好了。之后就可以開始網絡I/O操作了，即類同於普通文件的讀寫I/O操作。
int accept(int sockfd, struct sockaddr *addr, socklen_t *addrlen);accept函數的第一個參數為服務器的socket描述字，第二個參數為指向struct sockaddr *的指針，用於返回客戶端的協議地址，第三個參數為客戶端協議地址的長度。如果accpet成功，那么其返回值是由內核自動生成的一個全新的描述字，代表與返回客戶的TCP連接。
注意：accept的第一個參數為服務器的socket描述字，是服務器開始調用socket()函數生成的，稱為監聽socket描述字；而accept函數返回的是已連接的socket描述字。一個服務器通常通常僅僅只創建一個監聽socket描述字，它在該服務器的生命周期內一直存在。內核為每個由服務器進程接受的客戶連接創建了一個已連接socket描述字，當服務器完成了對某個客戶的服務，相應的已連接socket描述字就被關閉。
3.5 recv()、send()等函數
至此服務器與客戶已經建立好連接了。可以調用網絡I/O進行讀寫操作了，即實現了網咯中不同進程之間的通信！網絡I/O操作有下面幾組：
•read()/write()
•recv()/send()
•readv()/writev()
•recvmsg()/sendmsg()
•recvfrom()/sendto()
它們的聲明如下：
#include <unistd.h> ssize_t read(int fd, void *buf, size_t count); ssize_t write(int fd, const void *buf, size_t count); #include <sys/types.h> #include <sys/socket.h> ssize_t send(int sockfd, const void *buf, size_t len, int flags); ssize_t recv(int sockfd, void *buf, size_t len, int flags); ssize_t sendto(int sockfd, const void *buf, size_t len, int flags,const struct sockaddr *dest_addr, socklen_t addrlen); ssize_t recvfrom(int sockfd, void *buf, size_t len, int flags, struct sockaddr *src_addr, socklen_t *addrlen); ssize_t sendmsg(int sockfd, const struct msghdr *msg, int flags); ssize_t recvmsg(int sockfd, struct msghdr *msg, int flags);read函數是負責從fd中讀取內容。當讀成功時，read返回實際所讀的字節數，如果返回的值是0表示已經讀到文件的結束了，小於0表示出現了錯誤。如果錯誤為EINTR說明讀是由中斷引起的，如果是ECONNREST表示網絡連接出了問題。
write函數將buf中的nbytes字節內容寫入文件描述符fd。成功時返回寫的字節數。失敗時返回-1，並設置errno變量。 在網絡程序中，當我們向套接字文件描述符寫時有兩種可能。1)write的返回值大於0，表示寫了部分或者是全部的數據。2)返回的值小於0，此時出現了錯誤。我們要根據錯誤類型來處理。如果錯誤為EINTR表示在寫的時候出現了中斷錯誤。如果為EPIPE表示網絡連接出現了問題(對方已經關閉了連接)。
recv函數和send函數提供了read和write函數一樣的功能，不同的是他們提供了四個參數。前面的三個參數和read、write函數是一樣的。第四個參數可以是0或者是以下組合：
MSG_DONTROUTE：不查找表，是send函數使用的標志，這個標志告訴IP，目的主機在本地網絡上，沒有必要查找表，這個標志一般用在網絡診斷和路由程序里面。
MSG_OOB：表示可以接收和發送帶外數據。
MSG_PEEK：查看數據，並不從系統緩沖區移走數據。是recv函數使用的標志，表示只是從系統緩沖區中讀取內容，而不清楚系統緩沖區的內容。這樣在下次讀取的時候，依然是一樣的內容，一般在有個進程讀寫數據的時候使用這個標志。
MSG_WAITALL：等待所有數據，是recv函數的使用標志，表示等到所有的信息到達時才返回，使用這個標志的時候，recv返回一直阻塞，直到指定的條件滿足時，或者是發生了錯誤。
這里只描述同步Socket的send函數的執行流程。當調用該函數時，
（1）send先比較待發送數據的長度len和套接字s的發送緩沖的長度， 如果len大於s的發送緩沖區的長度，該函數返回SOCKET_ERROR；
（2）如果len小於或者等於s的發送緩沖區的長度，那么send先檢查協議s的發送緩沖中的數據是否正在發送，如果是就等待協議把數據發送完，如果協議還沒有開始發送s的發送緩沖中的數據或者s的發送緩沖中沒有數據，那么send就比較s的發送緩沖區的剩余空間和len
（3）如果len大於剩余空間大小，send就一直等待協議把s的發送緩沖中的數據發送完
（4）如果len小於剩余 空間大小，send就僅僅把buf中的數據copy到剩余空間里（注意並不是send把s的發送緩沖中的數據傳到連接的另一端的，而是協議傳的，send僅僅是把buf中的數據copy到s的發送緩沖區的剩余空間里）。
如果send函數copy數據成功，就返回實際copy的字節數，如果send在copy數據時出現錯誤，那么send就返回SOCKET_ERROR；如果send在等待協議傳送數據時網絡斷開的話，那么send函數也返回SOCKET_ERROR。
注意：send函數把buf中的數據成功copy到s的發送緩沖的剩余空間里后它就返回了，但是此時這些數據並不一定馬上被傳到連接的另一端。如果協議在后續的傳送過程中出現網絡錯誤的話，那么下一個socket函數就會返回SOCKET_ERROR。（每一個除send外的socket函數在執 行的最開始總要先等待套接字的發送緩沖中的數據被協議傳送完畢才能繼續，如果在等待時出現網絡錯誤，那么該Socket函數就返回 SOCKET_ERROR）
注意：在Unix系統下，如果send在等待協議傳送數據時網絡斷開的話，調用send的進程會接收到一個SIGPIPE信號，進程對該信號的默認處理是進程終止。
通過測試發現，異步socket的send函數在網絡剛剛斷開時還能發送返回相應的字節數，同時使用select檢測也是可寫的，但是過幾秒鍾之后，再send就會出錯了，返回-1。select也不能檢測出可寫了。
這里只描述同步Socket的recv函數的執行流程。當應用程序調用recv函數時，
（1）recv先等待s的發送緩沖中的數據被協議傳送完畢，如果協議在傳送s的發送緩沖中的數據時出現網絡錯誤，那么recv函數返回SOCKET_ERROR，
（2）如果s的發送緩沖中沒有數據或者數據被協議成功發送完畢后，recv先檢查套接字s的接收緩沖區，如果s接收緩沖區中沒有數據或者協議正在接收數據，那么recv就一直等待，直到協議把數據接收完畢。當協議把數據接收完畢，recv函數就把s的接收緩沖中的數據copy到buf中（注意協議接收到的數據可能大於buf的長度，所以 在這種情況下要調用幾次recv函數才能把s的接收緩沖中的數據copy完。recv函數僅僅是copy數據，真正的接收數據是協議來完成的），recv函數返回其實際copy的字節數。如果recv在copy時出錯，那么它返回SOCKET_ERROR；如果recv函數在等待協議接收數據時網絡中斷了，那么它返回0。
注意：在Unix系統下，如果recv函數在等待協議接收數據時網絡斷開了，那么調用recv的進程會接收到一個SIGPIPE信號，進程對該信號的默認處理是進程終止。
3.6 select（）函數
connect、accept、recv或recvfrom這樣的阻塞程序（所謂阻塞方式block，顧名思義，就是進程或是線程執行到這些函數時必須等待某個事件的發生，如果事件沒有發生，進程或線程就被阻塞，函數不能立即返回）。可是使用Select就可以完成非阻塞（所謂非阻塞方式non-block，就是進程或線程執行此函數時不必非要等待事件的發生，一旦執行肯定返回，以返回值的不同來反映函數的執行情況，如果事件發生則與阻塞方式相同，若事件沒有發生則返回一個代碼來告知事件未發生，而進程或線程繼續執行，所以效率較高）方式工作的程序，它能夠監視我們需要監視的文件描述符的變化情況——讀寫或是異常。
int select(int maxfdp,fd_set *readfds,fd_set *writefds,fd_set *errorfds,struct timeval*timeout); struct fd_set可以理解為一個集合，這個集合中存放的是文件描述符(filedescriptor)，即文件句柄，fd_set集合可以通過一些宏由人為來操作。
FD_ZERO(fd_set *set); //Clear all entries from the set. FD_SET(int fd, fd_set *set); //Add fd to the set. FD_CLR(int fd, fd_set *set); //Remove fd from the set. FD_ISSET(int fd, fd_set *set); //Return true if fd is in the set. struct timeval代表時間值。
struct timeval { int tv_sec; //seconds int tv_usec; //microseconds，注意這里是微秒不是毫秒 }; int maxfdp是一個整數值，是指集合中所有文件描述符的范圍，即所有文件描述符的最大值加1。
fd_set * readfds是指向fd_set結構的指針，這個集合中應該包括文件描述符，我們是要監視這些文件描述符的讀變化的，即我們關心是否可以從這些文件中讀取數據了，如果這個集合中有一個文件可讀，select就會返回一個大於0的值，表示有文件可讀，如果沒有可讀的文件，則根據timeout參數再判斷是否超時，若超出timeout的時間，select返回0，若發生錯誤返回負值。可以傳入NULL值，表示不關心任何文件的讀變化。
fd_set * writefds是指向fd_set結構的指針，這個集合中應該包括文件描述符，我們是要監視這些文件描述符的寫變化的，即我們關心是否可以向這些文件中寫入數據了，如果這個集合中有一個文件可寫，select就會返回一個大於0的值，表示有文件可寫，如果沒有可寫的文件，則根據timeout參數再判斷是否超時，若超出timeout的時間，select返回0，若發生錯誤返回負值。可以傳入NULL值，表示不關心任何文件的寫變化。
fd_set * errorfds同上面兩個參數的意圖，用來監視文件錯誤異常。
struct timeval * timeout是select的超時時間，這個參數至關重要，它可以使select處於三種狀態，第一，若將NULL以形參傳入，即不傳入時間結構，就是將select置於阻塞狀態，一定等到監視文件描述符集合中某個文件描述符發生變化為止；第二，若將時間值設為0秒0毫秒，就變成一個純粹的非阻塞函數，不管文件描述符是否有變化，都立刻返回繼續執行，文件無變化返回0，有變化返回一個正值；第三，timeout的值大於0，這就是等待的超時時間，即select在timeout時間內阻塞，超時時間之內有事件到來就返回了，否則在超時后不管怎樣一定返回，返回值同上述。
返回值：返回狀態發生變化的描述符總數。 負值：select錯誤 ；正值：某些文件可讀寫或出錯 ；0：等待超時，沒有可讀寫或錯誤的文件
理解select模型：
理解select模型的關鍵在於理解fd_set,為說明方便，取fd_set長度為1字節，fd_set中的每一bit可以對應一個文件描述符fd。則1字節長的fd_set最大可以對應8個fd。
（1）執行fd_set set;FD_ZERO(&set);則set用位表示是0000,0000。
（2）若fd＝5,執行FD_SET(fd,&set);后set變為0001,0000(第5位置為1)
（3）若再加入fd＝2，fd=1,則set變為0001,0011
（4）執行select(6,&set,0,NULL,NULL)阻塞等待
（5）若fd=1,fd=2上都發生可讀事件，則select返回，此時set變為0000,0011。注意：沒有事件發生的fd=5被清空。
基於上面的討論，可以輕松得出select模型的特點：
（1)可監控的文件描述符個數取決與sizeof(fd_set)的值。我這邊服務器上sizeof(fd_set)＝512，每bit表示一個文件描述符，則我服務器上支持的最大文件描述符是512*8=4096。據說可調，另有說雖然可調，但調整上限受於編譯內核時的變量值。
（2）將fd加入select監控集的同時，還要再使用一個數據結構array保存放到select監控集中的fd，一是用於再select返回后，array作為源數據和fd_set進行FD_ISSET判斷。二是select返回后會把以前加入的但並無事件發生的fd清空，則每次開始 select前都要重新從array取得fd逐一加入（FD_ZERO最先），掃描array的同時取得fd最大值maxfd，用於select的第一個參數。
（3）可見select模型必須在select前循環array（加fd，取maxfd），select返回后循環array（FD_ISSET判斷是否有時間發生）。
使用select和non-blocking實現server處理多client實例 
3.7 close()/shutdown()函數
int close(int sockfd); close 一個套接字的默認行為是把套接字標記為已關閉，然后立即返回到調用進程，該套接字描述符不能再由調用進程使用，也就是說它不能再作為read或write的第一個參數，然而TCP將嘗試發送已排隊等待發送到對端，發送完畢后發生的是正常的TCP連接終止序列。
在多進程並發服務器中，父子進程共享着套接字，套接字描述符引用計數記錄着共享着的進程個數，當父進程或某一子進程close掉套接字時，描述符引用計數會相應的減一，當引用計數仍大於零時，這個close調用就不會引發TCP的四路握手斷連過程。
int shutdown(int sockfd,int howto); 該函數的行為依賴於howto的值
SHUT_RD：值為0，關閉連接的讀這一半。
SHUT_WR：值為1，關閉連接的寫這一半。
SHUT_RDWR：值為2，連接的讀和寫都關閉。
終止網絡連接的通用方法是調用close函數。但使用shutdown能更好的控制斷連過程（使用第二個參數）。
close與shutdown的區別主要表現在：
close函數會關閉套接字ID，如果有其他的進程共享着這個套接字，那么它仍然是打開的，這個連接仍然可以用來讀和寫，並且有時候這是非常重要的 ，特別是對於多進程並發服務器來說。
而shutdown會切斷進程共享的套接字的所有連接，不管這個套接字的引用計數是否為零，那些試圖讀得進程將會接收到EOF標識，那些試圖寫的進程將會檢測到SIGPIPE信號，同時可利用shutdown的第二個參數選擇斷連的方式。 
4、 socket中TCP的三次握手建立連接詳解
我們知道tcp建立連接要進行“三次握手”，即交換三個分組。大致流程如下：
•客戶端向服務器發送一個SYN J
•服務器向客戶端響應一個SYN K，並對SYN J進行確認ACK J+1
•客戶端再想服務器發一個確認ACK K+1
只有就完了三次握手，但是這個三次握手發生在socket的哪幾個函數中： 
從圖中可以看出，當客戶端調用connect時，觸發了連接請求，向服務器發送了SYN J包，這時connect進入阻塞狀態；服務器監聽到連接請求，即收到SYN J包，調用accept函數接收請求向客戶端發送SYN K ，ACK J+1，這時accept進入阻塞狀態；客戶端收到服務器的SYN K ，ACK J+1之后，這時connect返回，並對SYN K進行確認；服務器收到ACK K+1時，accept返回，至此三次握手完畢，連接建立。
總結：客戶端的connect在三次握手的第二個次返回，而服務器端的accept在三次握手的第三次返回。
5、 socket中TCP的四次握手釋放連接詳解
上面介紹了socket中TCP的三次握手建立過程，及其涉及的socket函數。現在我們介紹socket中的四次握手釋放連接的過程，請看下圖： 
圖示過程如下：
•某個應用進程首先調用close主動關閉連接，這時TCP發送一個FIN M；
•另一端接收到FIN M之后，執行被動關閉，對這個FIN進行確認。它的接收也作為文件結束符傳遞給應用進程，因為FIN的接收意味着應用進程在相應的連接上再也接收不到額外數據；
•一段時間之后，接收到文件結束符的應用進程調用close關閉它的socket。這導致它的TCP也發送一個FIN N；
•接收到這個FIN的源發送端TCP對它進行確認。
這樣每個方向上都有一個FIN和ACK。
6、代碼
CLIENT
#include <string.h> #include <stdio.h> #include <sys/types.h> #include <sys/socket.h> #include <arpa/inet.h> #include <netinet/in.h> #include <netinet/tcp.h> #include <netdb.h> #define SERV_TCP_PORT 8000 /* server's port */ int main(int argc, char *argv[]) { int sockfd; struct sockaddr_in serv_addr; char *serv_host = "localhost"; struct hostent *host_ptr; int port; int buff_size = 0; /* command line: client [host [port]]*/ if(argc >= 2) serv_host = argv[1]; /* read the host if provided */ if(argc == 3) sscanf(argv[2], "%d", &port); /* read the port if provided */ else port = SERV_TCP_PORT; /* get the address of the host */ if((host_ptr = gethostbyname(serv_host)) == NULL) { perror("gethostbyname error"); exit(1); } if(host_ptr->h_addrtype != AF_INET) { perror("unknown address type"); exit(1); } bzero((char *) &serv_addr, sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = ((struct in_addr *)host_ptr->h_addr_list[0])->s_addr; serv_addr.sin_port = htons(port); /* open a TCP socket */ if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { perror("can't open stream socket"); exit(1); } /* connect to the server */ if(connect(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) { perror("can't connect to server"); exit(1); } /* write a message to the server */ write(sockfd, "hello world", sizeof("hello world")); close(sockfd); }SERVER
#include <string.h> #include <stdio.h> #include <sys/types.h> #include <sys/socket.h> #include <netinet/tcp.h> #include <arpa/inet.h> #define SERV_TCP_PORT 8000 /* server's port number */ #define MAX_SIZE 80 int main(int argc, char *argv[]) { int sockfd, newsockfd, clilen; struct sockaddr_in cli_addr, serv_addr; int port; char string[MAX_SIZE]; int len; /* command line: server [port_number] */ if(argc == 2) sscanf(argv[1], "%d", &port); /* read the port number if provided */ else port = SERV_TCP_PORT; /* open a TCP socket (an Internet stream socket) */ if((sockfd = socket(AF_INET, SOCK_STREAM, 0)) < 0) { perror("can't open stream socket"); exit(1); } /* bind the local address, so that the cliend can send to server */ bzero((char *) &serv_addr, sizeof(serv_addr)); serv_addr.sin_family = AF_INET; serv_addr.sin_addr.s_addr = htonl(INADDR_ANY); serv_addr.sin_port = htons(port); if(bind(sockfd, (struct sockaddr *) &serv_addr, sizeof(serv_addr)) < 0) { perror("can't bind local address"); exit(1); } /* listen to the socket */ listen(sockfd, 5); for(;;) { /* wait for a connection from a client; this is an iterative server */ clilen = sizeof(cli_addr); newsockfd = accept(sockfd, (struct sockaddr *) &cli_addr, &clilen); if(newsockfd < 0) { perror("can't bind local address"); } /* read a message from the client */ len = read(newsockfd, string, MAX_SIZE); /* make sure it's a proper string */ string[len] = 0; printf("%s\n", string); close(newsockfd); } }