① 用c語言寫個 socket tcp 的
#include <winsock2.h>
#include <stdio.h>
#include <pthread.h>
#pragma comment(lib,"ws2_32.lib")
typedef struct{
SOCKET accpt;
int lock;
}Arg;
void *transfer(void *arg)
{
Arg * info = (Arg *)arg;
SOCKET clientSock;
char recvbuf[102];
char sendBuf[] = "10";
int ret;
memcpy(&clientSock,(void*)&info->accpt,sizeof(clientSock));
info->lock =1;
while (TRUE)
{
ret = send(clientSock,sendBuf,2,0);
if (ret == -1)
{
break;
}
ret = recv(clientSock,recvbuf,102,0);
printf("%s ",recvbuf);
}
return (void *)0;
}
void* timer(void *arg)
{
time_t last = time(NULL);
time_t now;
int i = 20;
while(i--)
{
now = time(NULL);
if(now - last == 1)
{
printf("1s past! ");
last = now;
}
Sleep(500);
}
printf("timer exit. ");
return (void *)0;
}
int main(void) {
WSADATA wsaData;
SOCKET ListenSocket;
SOCKADDR_IN service,client;
int len = sizeof(client);
Arg argument;
pthread_t tid;
char sendBuf[] = "ID=2;WHAT=host";
int iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
if (iResult != NO_ERROR) {
printf("Error at WSAStartup() ");
return 1;
}
ListenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (ListenSocket == INVALID_SOCKET) {
printf("Error at socket(): %ld ", WSAGetLastError());
WSACleanup();
return 1;
}
service.sin_family = AF_INET;
service.sin_addr.s_addr = inet_addr("127.0.0.1");
service.sin_port = htons(27115);
if (bind( ListenSocket,
(SOCKADDR*) &service,
sizeof(service)) == SOCKET_ERROR) {
printf("bind() failed. ");
closesocket(ListenSocket);
WSACleanup();
return 1;
}
if (listen( ListenSocket, 1 ) == SOCKET_ERROR) {
printf("Error listening on socket. ");
closesocket(ListenSocket);
WSACleanup();
return 1;
}
argument.lock = 1;
printf("Waiting for client to connect... ");
pthread_create(&tid,NULL,timer,NULL);
while(TRUE){
argument.accpt = accept( ListenSocket, (SOCKADDR*)&client, &len );
if (argument.accpt == INVALID_SOCKET) {
printf("accept failed: %d ", WSAGetLastError());
closesocket(ListenSocket);
WSACleanup();
return 1;
} else {
printf("accept%s:%d ",inet_ntoa(client.sin_addr),client.sin_port);
while (!argument.lock);
argument.lock = 0;
// sendto(argument.accpt,sendBuf,sizeof(sendBuf),0,(SOCKADDR*)&client,len);
pthread_create(&tid,NULL,transfer,&argument);
//send(AcceptSocket,sendBuf,sizeof(sendBuf),0);
}
}
// No longer need server socket
closesocket(ListenSocket);
WSACleanup();
return 0;
}
發送數據格式按需求。可以發送字元串，也可以發送結構體。如果發送結構體的話，要注意序列化和反序列化。程序例子是伺服器對每個客戶端的connect動作起一個線程去交互。還有一個線程是定時器。
② Windows系統用C語言寫TCP通信
#include
#include
#include
#pragma comment(lib,"ws2_32.lib")
typedef struct{
SOCKET accpt;
int lock;
}Arg;
void *transfer(void *arg)
{
Arg * info = (Arg *)arg;
SOCKET clientSock;
char recvbuf[102];
char sendBuf[] = "10";
int ret;
memcpy(&clientSock,(void*)&info->accpt,sizeof(clientSock));
info->lock =1;
while (TRUE)
{
ret = send(clientSock,sendBuf,2,0);
if (ret == -1)
{
break;
}
ret = recv(clientSock,recvbuf,102,0);
printf("%s\n",recvbuf);
}
return (void *)0;
}
void* timer(void *arg)
{
time_t last = time(NULL);
time_t now;
int i = 20;
while(i--)
{
now = time(NULL);
if(now - last == 1)
{
printf("1s past!\n");
last = now;
}
Sleep(500);
}
printf("timer exit.\n");
return (void *)0;
}
int main(void) {
WSADATA wsaData;
SOCKET ListenSocket;
SOCKADDR_IN service,client;
int len = sizeof(client);
Arg argument;
pthread_t tid;
char sendBuf[] = "ID=2;WHAT=host";
int iResult = WSAStartup(MAKEWORD(2,2), &wsaData);
if (iResult != NO_ERROR) {
printf("Error at WSAStartup()\n");
return 1;
}
ListenSocket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if (ListenSocket == INVALID_SOCKET) {
printf("Error at socket(): %ld\n", WSAGetLastError());
WSACleanup();
return 1;
}
service.sin_family = AF_INET;
service.sin_addr.s_addr = inet_addr("127.0.0.1");
service.sin_port = htons(27115);
if (bind( ListenSocket,
(SOCKADDR*) &service,
sizeof(service)) == SOCKET_ERROR) {
printf("bind() failed.\n");
closesocket(ListenSocket);
WSACleanup();
return 1;
}
if (listen( ListenSocket, 1 ) == SOCKET_ERROR) {
printf("Error listening on socket.\n");
closesocket(ListenSocket);
WSACleanup();
return 1;
}
argument.lock = 1;
printf("Waiting for client to connect...\n");
pthread_create(&tid,NULL,timer,NULL);
while(TRUE){
argument.accpt = accept( ListenSocket, (SOCKADDR*)&client, &len );
if (argument.accpt == INVALID_SOCKET) {
printf("accept failed: %d\n", WSAGetLastError());
closesocket(ListenSocket);
WSACleanup();
return 1;
} else {
printf("accept%s:%d\n",inet_ntoa(client.sin_addr),client.sin_port);
while (!argument.lock);
argument.lock = 0;
// sendto(argument.accpt,sendBuf,sizeof(sendBuf),0,(SOCKADDR*)&client,len);
pthread_create(&tid,NULL,transfer,&argument);
//send(AcceptSocket,sendBuf,sizeof(sendBuf),0);
}
}
// No longer need server socket
closesocket(ListenSocket);
WSACleanup();
return 0;
}
③ C語言 TCP Client消息接收問題
你說的傳遞出去是傳遞給主線程嗎，如果是的話那就很簡單，因為同一個進程的線程之間共享一個堆棧的，你只需要定義一個全局變數，主線程和子線程都能訪問到。但是這樣你就需要注意訪問這個全局變數的時候的訪問沖突問題，一般這種問題是通過互斥鎖解決的，也就是在訪問全局變數之前先加鎖，訪問完了釋放鎖。
④ 在linux系統中用c語言編寫一個網路tcp主從通信的socket程序，要求發送數據包
沒有你想像的那麼復雜，其實監聽埠，然後read或者write就夠了。
⑤ 用C語言怎麼編寫截取TCP報文的程序
是說別的程序的網路通訊、還是一般的socket編程？？？？？ 如果是前者，用winpcap的JAVA版本。。。。。。。。。。。後者，就搜索java socket 編程 。。。。。。。。。。。。。
⑥ C語言編寫TCP的文件傳輸
粗略看了一下,你是用戶的是TCP不是UDP,注意一點TCP可靠安全但是需要你自己手動處理粘包問題.你要是想學網路編程,就需要學會分析和定製協議.我建議你先去看看TFTP的網路協議.所謂的通信就是我發請求給你,你給我應答(請求成功還是失敗).你剛學網路編程,直接是使用tcp不是很合適,你可以去看看TFTP的協議(向伺服器請求下載或者上傳文件).復雜一點的程序一搬都需要定製網路協議,tcp則還需要處理粘包問題.如果你想學,可以和我聯系,我可以發你資料→_→
⑦ 求一個C語言的TCP 客戶/服務 連接示例代碼
#include <stdio.h>
#include <winsock2.h>
#pragma comment(lib, "ws2_32.lib")
void main() {
// 初始化
WSADATA wsaData;
int iResult = WSAStartup( MAKEWORD(2,2), &wsaData );
if ( iResult != NO_ERROR )
printf("Error at WSAStartup()\n");
// 建立socket
SOCKET server;
server = socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
if ( server == INVALID_SOCKET ) {
printf( "Error at socket(): %ld\n", WSAGetLastError() );
WSACleanup();
return;
}
// 綁定socket
sockaddr_in service;
service.sin_family = AF_INET;
service.sin_addr.s_addr = inet_addr( "127.0.0.1" );
service.sin_port = htons( 27015 );
if ( bind( server, (SOCKADDR*) &service, sizeof(service) ) == SOCKET_ERROR ) {
printf( "bind() failed.\n" );
closesocket(server);
return;
}
// 監聽 socket
if ( listen( server, 1 ) == SOCKET_ERROR )
printf( "Error listening on socket.\n");
// 接受連接
SOCKET AcceptSocket;
printf( "Waiting for a client to connect...\n" );
while (1) {
AcceptSocket = SOCKET_ERROR;
while ( AcceptSocket == SOCKET_ERROR ) {
AcceptSocket = accept( server, NULL, NULL );
}
printf( "Client Connected.\n");
server = AcceptSocket;
break;
}
// 發送接受數據
int bytesSent;
int bytesRecv = SOCKET_ERROR;
char sendbuf[32] = "Server: Sending Data.";
char recvbuf[32] = "";
bytesRecv = recv( server, recvbuf, 32, 0 );
printf( "Bytes Recv: %ld\n", bytesRecv );
bytesSent = send( server, sendbuf, strlen(sendbuf), 0 );
printf( "Bytes Sent: %ld\n", bytesSent );
return;
}
SERVER的
⑧ 求C語言下的TCP/IP協議的工作流程圖
這個問題太專業了
給你點TCP/IP協議相關的介紹吧，希望可以對你有用，雖然你可能已經知道了。
TCP/IP協議介紹
TCP/IP的通訊協議
這部分簡要介紹一下TCP/IP的內部結構，為討論與互聯網有關的安全問題打下基礎。TCP/IP協議組之所以流行，部分原因是因為它可以用在各種各樣的信道和底層協議（例如T1和X.25、乙太網以及RS-232串列介面）之上。確切地說，TCP/IP協議是一組包括TCP協議和IP協議，UDP（User Datagram Protocol）協議、ICMP（Internet Control Message Protocol）協議和其他一些協議的協議組。
TCP/IP整體構架概述
TCP/IP協議並不完全符合OSI的七層參考模型。傳統的開放式系統互連參考模型，是一種通信協議的7層抽象的參考模型,其中每一層執行某一特定任務。該模型的目的是使各種硬體在相同的層次上相互通信。這7層是:物理層、數據鏈路層、網路層、傳輸層、話路層、表示層和應用層。而TCP/IP通訊協議採用了4層的層級結構，每一層都呼叫它的下一層所提供的網路來完成自己的需求。這4層分別為：
應用層：應用程序間溝通的層，如簡單電子郵件傳輸（SMTP）、文件傳輸協議（FTP）、網路遠程訪問協議（Telnet）等。
傳輸層：在此層中，它提供了節點間的數據傳送服務，如傳輸控制協議（TCP）、用戶數據報協議（UDP）等，TCP和UDP給數據包加入傳輸數據並把它傳輸到下一層中，這一層負責傳送數據，並且確定數據已被送達並接收。
互連網路層：負責提供基本的數據封包傳送功能，讓每一塊數據包都能夠到達目的主機（但不檢查是否被正確接收），如網際協議（IP）。
網路介面層：對實際的網路媒體的管理，定義如何使用實際網路（如Ethernet、Serial Line等）來傳送數據。
TCP/IP中的協議
以下簡單介紹TCP/IP中的協議都具備什麼樣的功能，都是如何工作的：
1． IP
網際協議IP是TCP/IP的心臟，也是網路層中最重要的協議。
IP層接收由更低層（網路介面層例如乙太網設備驅動程序）發來的數據包，並把該數據包發送到更高層---TCP或UDP層；相反，IP層也把從TCP或UDP層接收來的數據包傳送到更低層。IP數據包是不可靠的，因為IP並沒有做任何事情來確認數據包是按順序發送的或者沒有被破壞。IP數據包中含有發送它的主機的地址（源地址）和接收它的主機的地址（目的地址）。
高層的TCP和UDP服務在接收數據包時，通常假設包中的源地址是有效的。也可以這樣說，IP地址形成了許多服務的認證基礎，這些服務相信數據包是從一個有效的主機發送來的。IP確認包含一個選項，叫作IP source routing，可以用來指定一條源地址和目的地址之間的直接路徑。對於一些TCP和UDP的服務來說，使用了該選項的IP包好像是從路徑上的最後一個系統傳遞過來的，而不是來自於它的真實地點。這個選項是為了測試而存在的，說明了它可以被用來欺騙系統來進行平常是被禁止的連接。那麼，許多依靠IP源地址做確認的服務將產生問題並且會被非法入侵。
2. TCP
如果IP數據包中有已經封好的TCP數據包，那麼IP將把它們向『上』傳送到TCP層。TCP將包排序並進行錯誤檢查，同時實現虛電路間的連接。TCP數據包中包括序號和確認，所以未按照順序收到的包可以被排序，而損壞的包可以被重傳。
TCP將它的信息送到更高層的應用程序，例如Telnet的服務程序和客戶程序。應用程序輪流將信息送回TCP層，TCP層便將它們向下傳送到IP層，設備驅動程序和物理介質，最後到接收方。
面向連接的服務（例如Telnet、FTP、rlogin、X Windows和SMTP）需要高度的可靠性，所以它們使用了TCP。DNS在某些情況下使用TCP（發送和接收域名資料庫），但使用UDP傳送有關單個主機的信息。
3.UDP
UDP與TCP位於同一層，但對於數據包的順序錯誤或重發。因此，UDP不被應用於那些使用虛電路的面向連接的服務，UDP主要用於那些面向查詢---應答的服務，例如NFS。相對於FTP或Telnet，這些服務需要交換的信息量較小。使用UDP的服務包括NTP（網落時間協議）和DNS（DNS也使用TCP）。
欺騙UDP包比欺騙TCP包更容易，因為UDP沒有建立初始化連接（也可以稱為握手）（因為在兩個系統間沒有虛電路），也就是說，與UDP相關的服務面臨著更大的危險。
4.ICMP
ICMP與IP位於同一層，它被用來傳送IP的的控制信息。它主要是用來提供有關通向目的地址的路徑信息。ICMP的『Redirect』信息通知主機通向其他系統的更准確的路徑，而『Unreachable』信息則指出路徑有問題。另外，如果路徑不可用了，ICMP可以使TCP連接『體面地』終止。PING是最常用的基於ICMP的服務。
5. TCP和UDP的埠結構
TCP和UDP服務通常有一個客戶/伺服器的關系，例如，一個Telnet服務進程開始在系統上處於空閑狀態，等待著連接。用戶使用Telnet客戶程序與服務進程建立一個連接。客戶程序向服務進程寫入信息，服務進程讀出信息並發出響應，客戶程序讀出響應並向用戶報告。因而，這個連接是雙工的，可以用來進行讀寫。
兩個系統間的多重Telnet連接是如何相互確認並協調一致呢？TCP或UDP連接唯一地使用每個信息中的如下四項進行確認：
源IP地址 發送包的IP地址。
目的IP地址 接收包的IP地址。
源埠 源系統上的連接的埠。
目的埠 目的系統上的連接的埠。
埠是一個軟體結構，被客戶程序或服務進程用來發送和接收信息。一個埠對應一個16比特的數。服務進程通常使用一個固定的埠，例如，SMTP使用25、Xwindows使用6000。這些埠號是『廣為人知』的，因為在建立與特定的主機或服務的連接時，需要這些地址和目的地址進行通訊。
相信大家都聽說過TCP/IP這個詞，這個詞好像無處不在，時時都會在你面前跳出來。那TCP/IP到底是什麼意思呢？
TCP/IP其實是兩個網路基礎協議：IP協議、TCP協議名稱的組合。下面我們分別來看看這兩個無處不在的協議。
IP協議
IP（Internet Protocol）協議的英文名直譯就是：網際網路協議。從這個名稱我們就可以知道IP協議的重要性。在現實生活中，我們進行貨物運輸時都是把貨物包裝成一個個的紙箱或者是集裝箱之後才進行運輸，在網路世界中各種信息也是通過類似的方式進行傳輸的。IP協議規定了數據傳輸時的基本單元和格式。如果比作貨物運輸，IP協議規定了貨物打包時的包裝箱尺寸和包裝的程序。 除了這些以外，IP協議還定義了數據包的遞交辦法和路由選擇。同樣用貨物運輸做比喻，IP協議規定了貨物的運輸方法和運輸路線。
TCP協議
我們已經知道了IP協議很重要，IP協議已經規定了數據傳輸的主要內容，那TCP（Transmission Control Protocol）協議是做什麼的呢？不知大家發現沒有，在IP協議中定義的傳輸是單向的，也就是說發出去的貨物對方有沒有收到我們是不知道的。就好像8毛錢一份的平信一樣。那對於重要的信件我們要寄掛號信怎麼辦呢？TCP協議就是幫我們寄「掛號信」的。TCP協議提供了可靠的面向對象的數據流傳輸服務的規則和約定。簡單的說在TCP模式中，對方發一個數據包給你，你要發一個確認數據包給對方。通過這種確認來提供可靠性。
TCP/IP（Transmission Control Protocol/Internet Protocol的簡寫，中文譯名為傳輸控制協議/互聯網路協議）協議是Internet最基本的協議，簡單地說，就是由底層的IP協議和TCP協議組成的。TCP/IP協議的開發工作始於70年代，是用於互聯網的第一套協議。
1.1 TCP/IP參考模型
TCP/IP協議的開發研製人員將Internet分為五個層次，以便於理解，它也稱為互聯網分層模型或互聯網分層參考模型，如下表：
應用層（第五層）
傳輸層（第四層）
互聯網層（第三層）
網路介面層（第二層）
物理層（第一層）
物理層：對應於網路的基本硬體，這也是Internet物理構成，即我們可以看得見的硬設備，如PC機、互連網伺服器、網路設備等，必須對這些硬設備的電氣特性作一個規范，使這些設備都能夠互相連接並兼容使用。
網路介面層：它定義了將資料組成正確幀的規程和在網路中傳輸幀的規程，幀是指一串資料，它是資料在網路中傳輸的單位。
互聯網層：本層定義了互聯網中傳輸的「信息包」格式，以及從一個用戶通過一個或多個路由器到最終目標的"信息包"轉發機制。
傳輸層：為兩個用戶進程之間建立、管理和拆除可靠而又有效的端到端連接。
應用層：它定義了應用程序使用互聯網的規程。
1. 2 網間協議IP
Internet 上使用的一個關鍵的底層協議是網際協議，通常稱IP協議。我們利用一個共同遵守的通信協議，從而使 Internet 成為一個允許連接不同類型的計算機和不同操作系統的網路。要使兩台計算機彼此之間進行通信，必須使兩台計算機使用同一種"語言"。通信協議正像兩台計算機交換信息所使用的共同語言，它規定了通信雙方在通信中所應共同遵守的約定。
計算機的通信協議精確地定義了計算機在彼此通信過程的所有細節。例如，每台計算機發送的信息格式和含義，在什麼情況下應發送規定的特殊信息，以及接收方的計算機應做出哪些應答等等。
網際協議IP協議提供了能適應各種各樣網路硬體的靈活性，對底層網路硬體幾乎沒有任何要求，任何一個網路只要可以從一個地點向另一個地點傳送二進制數據，就可以使用IP協議加入 Internet 了。
如果希望能在 Internet 上進行交流和通信，則每台連上 Internet 的計算機都必須遵守IP協議。為此使用 Internet 的每台計算機都必須運行IP軟體，以便時刻准備發送或接收信息。
IP協議對於網路通信有著重要的意義：網路中的計算機通過安裝IP軟體，使許許多多的區域網絡構成了一個龐大而又嚴密的通信系統。從而使 Internet 看起來好像是真實存在的，但實際上它是一種並不存在的虛擬網路，只不過是利用IP協議把全世界上所有願意接入 Internet 的計算機區域網絡連接起來，使得它們彼此之間都能夠通信。
1.3 傳輸控制協議TCP
盡管計算機通過安裝IP軟體，從而保證了計算機之間可以發送和接收資料，但IP協議還不能解決資料分組在傳輸過程中可能出現的問題。因此，若要解決可能出現的問題，連上 Internet 的計算機還需要安裝TCP協議來提供可靠的並且無差錯的通信服務。
TCP協議被稱作一種端對端協議。這是因為它為兩台計算機之間的連接起了重要作用：當一台計算機需要與另一台遠程計算機連接時，TCP協議會讓它們建立一個連接、發送和接收資料以及終止連接。
傳輸控制協議TCP協議利用重發技術和擁塞控制機制，向應用程序提供可靠的通信連接，使它能夠自動適應網上的各種變化。即使在 Internet 暫時出現堵塞的情況下，TCP也能夠保證通信的可靠。
眾所周知， Internet 是一個龐大的國際性網路，網路上的擁擠和空閑時間總是交替不定的，加上傳送的距離也遠近不同，所以傳輸資料所用時間也會變化不定。TCP協議具有自動調整"超時值"的功能，能很好地適應 Internet 上各種各樣的變化，確保傳輸數值的正確。
因此，從上面我們可以了解到：IP協議只保證計算機能發送和接收分組資料，而TCP協議則可提供一個可靠的、可流控的、全雙工的信息流傳輸服務。
⑨ 怎樣用c語言或者c++實現tcp，並實現文本傳輸
TCP協議實現文件傳輸
使用TCP協議實現傳輸文件
程序分為發送端和接收端。首先在傳輸文件數據之前，發送端會把將裝有文件名稱和文件長度等
信息的數據包發送至接收端。接收端收到文件名稱和文件長度信息後會創建好空白文件。接著開始傳輸
文件數據。下面介紹實現功能的主要過程：
1.創建套接字、綁定、監聽、連接、接受連接
//創建TCP協議的套接字
m_Socket = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
if(SOCKET_ERROR == m_Socket)
AfxMessageBox("Create Socket Error! ", 0, 0);
//綁定與監聽
SOCKADDR_IN addrSrv;
addrSrv.sin_addr.s_addr = inet_addr(sIP);
addrSrv.sin_family = AF_INET;
addrSrv.sin_port = htons(Port);
int ret = bind(m_Socket, (SOCKADDR *)&addrSrv, sizeof(SOCKADDR));
if(ret==SOCKET_ERROR)
AfxMessageBox("Bind Socket Error!", 0, 0);
//連接
SOCKADDR_IN ServerAddr;
ServerAddr.sin_addr.s_addr = inet_addr(ServerAddr_in);
ServerAddr.sin_family = AF_INET;
ServerAddr.sin_port = htons(ServerPort);
int Result = connect(m_Socket, (struct sockaddr*)&ServerAddr, sizeof(struct sockaddr));
if(SOCKET_ERROR == Result)
AfxMessageBox("Connet Failed!");
//接受連接
SOCKADDR_IN ClientAddr;
int len = sizeof(SOCKADDR_IN);
SOCKET ClientSock = accept(m_Socket, (struct sockaddr*)&ClientAddr, &len);
if(SOCKET_ERROR == ClientSock)
AfxMessageBox("Accept Failed!");
2.聲明宏和結構體
聲明套接字緩沖區和一次發送文件數據的緩沖區大小
#define SOCKET_BUFF 80000 //套接字緩沖區大小
#define PACK_BUFF 50000 //數據包緩沖區大小
聲明文件I/O緩沖區和最大文件路徑長度
#define FILE_NAME_MAX 100 //文件路徑最大長度
#define FILE_IO_BUFF PACK_BUFF //文件IO緩沖區
//文件信息
typedef struct _FileInfor
{
u_long ulFileLen;
char sFileName[ FILE_NAME_MAX ];
}_FileInfor;
//數據包
typedef struct _DataPack
{
char cType; //'D'為數據 'M'為文件信息
int nPackLen;
char sContent[ PACK_BUFF ]; //數據包緩沖區
u_long nPosition; //數據在文件中的位置
int nContentLen; //數據位元組數
_FileInfor FileInfor; //文件信息
}_DataPack;
3.發送端
//發送線程需要的全局變數
char sPath[FILE_NAME_MAX]; //文件地址
u_long FileByteCount; //文件大小
SOCKET ClientSocket; //
(1)設置套接字發送緩沖區大小，在32位Windows XP環境下，系統為每個套接字分配的默認發送數據緩
沖區為8192位元組。由於傳輸的文件很大，可能幾十兆，或者更大。那麼系統為每個套接字分配的默認
緩沖區顯然過小。為此在創建套接字之後，需要修改套接字發送數據緩沖尺寸。在這里我修改為80k，
差不多可以夠用了。
//設置套接字發送緩沖區
int nBuf = SOCKET_BUFF;
int nBufLen = sizeof(nBuf);
int nRe = setsockopt(ClientSock, SOL_SOCKET, SO_SNDBUF, (char*)&nBuf, nBufLen);
if(SOCKET_ERROR == nRe)
AfxMessageBox("setsockopt error!");
//檢查緩沖區是否設置成功
nRe = getsockopt(ClientSock, SOL_SOCKET, SO_SNDBUF, (char*)&nBuf, &nBufLen);
if(SOCKET_BUFF != nBuf)
AfxMessageBox("檢查緩沖區:setsockopt error!");
(2)測量文件大小並發送文件大小和名稱給客戶端
首先使用C庫函數對源文件進行測量
//得到文件地址
LPTSTR lpPath = m_sPath.GetBuffer( m_sPath.GetLength ());
//打開文件
FILE *File = fopen(lpPath, "rb");
if(NULL == File)
AfxMessageBox("打開文件失敗!");
//測量文件大小
char Buff[PACK_BUFF];
u_long ulFaceReadByte;
FileByteCount = 0;
fseek(File, 0, SEEK_SET);
while(!feof(File))
{
ulFaceReadByte = fread(Buff, 1, 1, File);
FileByteCount += ulFaceReadByte;
}
//關閉文件
int nRe = fclose(File);
if(nRe)
AfxMessageBox("關閉文件失敗!");
此時以獲取源文件的長度，我們將文件長度和文件名稱放到數據包中，設置數據包為'M'類型。
//打包
_DataPack Pack;
Pack.cType = 'M';
Pack.nPackLen = sizeof(Pack);
//取得文件名
ZeroMemory(Pack.FileInfor.sFileName, FILE_NAME_MAX);
GetFIieNameFromPath(lpPath, Pack.FileInfor.sFileName);
Pack.FileInfor.ulFileLen = FileByteCount;
接著使用send()將打包完成的數據包發送給接收端,把發送線程的全局變數初始化，並創建發送線
程，文件數據將由發送線程負責發送
//發送數據包 文件大小和名稱
nRe = send(m_ClientSockFd.fd_array[0], (char*)&Pack, Pack.nPackLen, 0);
if(SOCKET_ERROR == nRe)
AfxMessageBox("Send File Size Failed!");
//線程准備全局變數
strcpy(sPath, m_sPath);
ClientSocket = m_ClientSockFd.fd_array[0];
//啟動線程發送文件
DWORD ID;
m_hSendThread = CreateThread(0, 0, SendDataThrad, 0, 0, &ID);
(3)發送文件數據線程。先打開源文件，為了一次讀取大量數據將文件緩沖區設置為FILE_IO_BUFF大小，
然後將讀取的數據打包並發送。這樣不斷地讀、不斷地發送，直到將整個文件發送完為止。
DWORD __stdcall CServerDlg::SendDataThrad(LPVOID LpP)
{
//打開文件
FILE *File = fopen(sPath, "rb");
if(NULL == File)
{
AfxMessageBox("SendDataThrad中打開文件失敗!");
return 1;
}
//設置文件緩沖區
int nBuff = FILE_IO_BUFF;
if(setvbuf(File, (char*)&nBuff, _IOFBF, sizeof(nBuff)))
AfxMessageBox("設置文件緩沖區失敗!");
//讀取文件數據並發送
u_long ulFlagCount = 0; //記錄讀了多少數據
u_long FaceReadByte = 0; //一次實際讀取的位元組數
char sBuff[PACK_BUFF];
ZeroMemory(sBuff, PACK_BUFF);
fseek(File, 0, SEEK_SET);
while (!feof(File))
{
FaceReadByte = fread(sBuff, 1, PACK_BUFF, File);
//打包
_DataPack DataPack;
DataPack.cType = 'D';
DataPack.nPackLen = sizeof(DataPack);
DataPack.nContentLen = FaceReadByte;
CopyMemory(DataPack.sContent, sBuff, FaceReadByte);
DataPack.nPosition = ulFlagCount;
//發送
int nResult = send(ClientSocket, (char*)&DataPack, DataPack.nPackLen, 0);
if (SOCKET_ERROR == nResult)
{
AfxMessageBox("SendDataThrad中發送數據失敗!");
}else
ulFlagCount += FaceReadByte; //記錄發送位元組數
}
AfxMessageBox("發送結束");
//關閉
int nRe = fclose(File);
if(nRe)
AfxMessageBox("SendDataThrad中關閉文件失敗!");
return 0;
}
4.接收端
//接收線程用的全局變數
_FileInfor FileInfor; //文件信息
u_long ulWriteByte; //記錄總共寫入的位元組
char lpPath[FILE_NAME_MAX]; //文件路徑
char sFilePathAndName[FILE_NAME_MAX]; //完整的文件路徑
(1)設置套接字接收緩沖區大小。
//設置套接字接收緩沖區
int nBuf = SOCKET_BUFF;
int nBufLen = sizeof(nBuf);
SOCKET ClientSock = m_Sock.GetSocket();
int nRe = setsockopt(ClientSock, SOL_SOCKET, SO_RCVBUF, (char*)&nBuf, nBufLen);
if(SOCKET_ERROR == nRe)
AfxMessageBox("setsockopt error!");
//檢查緩沖區是否設置成功
nRe = getsockopt(ClientSock, SOL_SOCKET, SO_RCVBUF, (char*)&nBuf, &nBufLen);
if(SOCKET_BUFF != nBuf)
AfxMessageBox("檢查緩沖區:setsockopt error!");
(2)接收文件信息和文件數據線程。先判斷數據包是屬於文件信息還是文件類型，如果是文件信息就根
據信息創建空文件，如果是文件數據就將數據已追加的方式寫進目的文件中。
DWORD __stdcall CClientDlg::ReceiveDataPro(LPVOID LpP)
{
CSocket_Win32 *pCSock = (CSocket_Win32*)LpP;
u_long ulWriteByteCount = 0;
while (1)
{
_DataPack DataPack;
ZeroMemory(&DataPack, sizeof(DataPack));
if(!(*pCSock).Receive(&DataPack, sizeof(DataPack)))
{
AfxMessageBox("Receive DataPack Failed!");
}
//判斷數據包類型
if('M' == DataPack.cType) //包為文件信息
{
//接收文件信息
FileInfor.ulFileLen = DataPack.FileInfor.ulFileLen; //獲取文件長度
strcpy(FileInfor.sFileName, DataPack.FileInfor.sFileName); //獲取文件名稱
//得到文件目錄
char sFilePath[FILE_NAME_MAX];
ZeroMemory(sFilePath, FILE_NAME_MAX);
strcpy(sFilePath, lpPath);
strcat(sFilePath, FileInfor.sFileName);
strcat(sFilePathAndName, sFilePath); //保存完整的文件路徑
//創建文件
SECURITY_ATTRIBUTES attr;
attr.nLength = FileInfor.ulFileLen;
attr.lpSecurityDescriptor = NULL;
HANDLE hRe = CreateFile(sFilePath, GENERIC_WRITE, FILE_SHARE_WRITE, &attr, CREATE_ALWAYS, FILE_ATTRIBUTE_NORMAL, 0);
if(INVALID_HANDLE_VALUE == hRe)
AfxMessageBox("創建文件失敗!");
bool bRe = ::CloseHandle(hRe);
//可以開始接受文件
bIsStartReceive = true;
}else if('D' == DataPack.cType) //包為文件數據
{
//打開文件
char sPath[FILE_NAME_MAX];
strcpy(sPath, sFilePathAndName);
FILE *File = fopen(sPath, "ab");
if(0 == File)
AfxMessageBox("打開文件失敗!");
//設置文件緩沖區
int nBuff = FILE_IO_BUFF;
if(setvbuf(File, (char*)&nBuff, _IOFBF, sizeof(nBuff)))
AfxMessageBox("設置文件緩沖區失敗!");
//定位文件
u_long nPosition = DataPack.nPosition;
int nRe = fseek(File, nPosition, SEEK_SET);
if(nRe)
AfxMessageBox("SendDataThrad中定位失敗!");
//寫文件
u_long nNumberOfBytesWritten = fwrite(&DataPack.sContent, 1, DataPack.nContentLen, File);
if(DataPack.nContentLen != nNumberOfBytesWritten)
AfxMessageBox("寫文件失敗!");
else
{
ulWriteByteCount += nNumberOfBytesWritten;
}
fflush(File); //清除文件緩沖區
//關閉文件
nRe = fclose(File);
if(nRe)
AfxMessageBox("關閉文件失敗!");
if(ulWriteByteCount >= FileInfor.ulFileLen)
{
AfxMessageBox("接收結束");
break;
}
}
}
return 0;
}
⑩ 求一C語言編寫的TCP/IP協議
#include "stdio'h"