Linux_socket編程入門（C++）
參考資料
實現(xiàn)思路
Socket編程主要分為兩部分聂儒，Server端以及Client端，以下依次從這兩方面開始講解。
Server端
需要完成的任務(wù)
- 創(chuàng)建嵌套字( socket() )
- 綁定嵌套字到IP地址以及端口上( bind() )
- 將嵌套字設(shè)置到監(jiān)聽模式監(jiān)聽請求( listen() )
- 請求到來后哆窿，接受請求农曲，返回一個新的連接嵌套字( accept() )
- 進(jìn)行通信( send()/recv() )
- 關(guān)閉嵌套字( close() )
所用到的一些函數(shù)以及結(jié)構(gòu)
-
socketaddr_in:
- sin_family （地址簇）
- sin_port（端口）
- sin_addr（地址）
-
socket( domain, type, protocol):返回值為-1時連接失敗
- domain (協(xié)議簇)
- type (數(shù)據(jù)傳輸類型)
- protocol (協(xié)議類型)
-
bind( sockfd, addr, addrlen)
- sockfd （嵌套字）
- addr （將地址賦值給嵌套字）
- addrlen （addr所指向結(jié)構(gòu)體的字節(jié)長度）
-
listen( sock, backlog)
- sock ( 監(jiān)聽狀態(tài)的嵌套字 )
- backlog ( 請求隊列的最大長度 )
- accept( sock, sockaddr, addrlen):接受客戶端請求
-
send( sock, buf, len, flag )
- sock（嵌套字）
- buf（所要發(fā)送數(shù)據(jù)社搅，緩沖區(qū)大小）
- len（所要發(fā)送數(shù)據(jù)字節(jié)數(shù)）
- flags（發(fā)送數(shù)據(jù)時的選項）
- recv():類似于send()
Client端
需要完成的任務(wù)
- 創(chuàng)建嵌套字( socket() )
- 向服務(wù)器發(fā)送連接請求( connect() )
- 和服務(wù)器進(jìn)行通信( send()/recv() )
- 關(guān)閉嵌套字( close() )
所用到的一些函數(shù)以及結(jié)構(gòu)
- connec( sockfd, addr, addrlen)：返回值為-1時連接失敗
源代碼
server.cpp
#include <iostream>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
using namespace std;
int main()
{
int client, server;
int portNum = 1500;
bool isExit = false;
int bufsize = 1024;
char buffer[bufsize];
struct sockaddr_in server_addr;
socklen_t size;
//init socket.
client = socket(AF_INET, SOCK_STREAM, 0); //AF_INET指明使用TCP/IP協(xié)議簇
//SOCK_STREAM指明使用流式嵌套字
//使用default 協(xié)議類型
if (client < 0) //返回值為-1乳规，連接失敗
{
cout<<"=> Error establishing connection."<<endl;
exit(1);
}
cout<<"\n=> Socket server has been created."<<endl;
server_addr.sin_family = AF_INET;
server_addr.sin_addr.s_addr = htons(INADDR_ANY); //INADDR_ANY能夠收到任意一塊網(wǎng)卡的連接
server_addr.sin_port = htons(portNum);
//binding socket
if(bind(client, (struct sockaddr*)&server_addr, sizeof(server_addr))<0)
{
cout<<"=> Error binding socket..."<<endl;
exit(1);
}
size = sizeof(server_addr);
cout<<"=> Looking for client"<<endl;
//listening socket
listen(client,1);
//accept client
server = accept(client, (struct sockaddr*)&server_addr,&size);
if(server < 0)
{
cout<<"=> Error on accepting..."<<endl;
exit(1);
}
while(server > 0)
{
strcpy(buffer,"Server connected...\n");
send(server, buffer, bufsize, 0);
cout<<"=> Connected with client..."<<endl;
cout<<"\n=> Enter # to end the connection\n"<<endl;
cout<<"Client: ";
do{
recv(server, buffer, bufsize, 0);
cout << buffer << " ";
if(*buffer == '#')
{
*buffer = '*';
isExit = true;
}
}while(*buffer != '*');
do{
cout<<"\nServer: ";
do{
cin >> buffer;
send(server, buffer, bufsize, 0);
if(*buffer == '#')
{
send(server, buffer, bufsize, 0);
*buffer = '*';
isExit = true;
}
}while (*buffer != '*');
cout<<"Client: ";
do{
recv(server, buffer, bufsize, 0);
cout << buffer <<" ";
if(*buffer == '#')
{
*buffer == '*';
isExit = true;
}
}while(*buffer != '*');
}while(!isExit);
cout<<"\n\n=> Connection terminated..."<< endl;
cout<<"=> Goodbye..." << endl;
isExit = false;
exit(1);
}
close(client);
return 0;
}
client.cpp
/*
Note the server doesn't need to know the clients port number
but the client needs to the servers port number
*/
#include <iostream>
#include <string.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <netdb.h>
using namespace std;
int main()
{
int client, server;
int portNum = 1500; // note the server and clients Ip are the same
bool isExit = false;
int bufsize = 1024;
char buffer[bufsize];
// char *ip = "127.0.0.1";
struct sockaddr_in server_addr;
//init socket
client = socket(AF_INET, SOCK_STREAM, 0);
if (client < 0)
{
cout<<"\n=> Error creating socket."<<endl;
exit(1);
}
cout<<"\n=> Socket client has been created" <<endl;
server_addr.sin_family = AF_INET;
server_addr.sin_port = htons(portNum);
//connecting socket server
if(connect(client, (struct sockaddr*)&server_addr, sizeof(server_addr)) == 0)
{
cout << "=> Connecting to server..."<< endl;
}
recv(client, buffer, bufsize, 0);
cout<< "=> Connection confirmed" << endl;
cout<< "\n=> Enter # to end the connection\n" << endl;
do{
cout<<"Client: ";
do{
cin >> buffer;
send(client, buffer, bufsize, 0);
if(*buffer == '#')
{
send(client, buffer, bufsize, 0);
*buffer = '*';
isExit = true;
}
} while(*buffer != 42);
cout<<"Server: ";
do{
recv(client, buffer, bufsize, 0);
cout << buffer << " ";
if(*buffer == '#')
{
*buffer = '*';
isExit = true;
}
}while(*buffer != 42);
cout<<endl;
}while(!isExit);
cout<<"\nConnection terminated..."<< endl;
cout<<"Goodbye..." << endl;
close(client);
return 0;
}