建站
咨詢
售后
建站咨詢
新聞中心
Linux作為一款廣泛使用的操作系統(tǒng)，其受歡迎程度主要歸功于它的穩(wěn)定性、高度的可定制化和豐富的開源軟件庫。在Linux下，套接字（Socket）是一種常見的網(wǎng)絡(luò)編程模型，它允許不同的應(yīng)用程序之間在網(wǎng)絡(luò)上進行通信。本文將介紹Linux套接字編程的基礎(chǔ)知識，并提供一些用于掌握Socket使用技巧的實用提示。
10年積累的網(wǎng)站建設(shè)、網(wǎng)站設(shè)計經(jīng)驗，可以快速應(yīng)對客戶對網(wǎng)站的新想法和需求。提供各種問題對應(yīng)的解決方案。讓選擇我們的客戶得到更好、更有力的網(wǎng)絡(luò)服務(wù)。我雖然不認識你，你也不認識我。但先網(wǎng)站設(shè)計后付款的網(wǎng)站建設(shè)流程，更有雅安免費網(wǎng)站建設(shè)讓你可以放心的選擇與我們合作。
什么是Linux套接字編程？
Linux套接字編程是一種基于Socket API的網(wǎng)絡(luò)編程，使用Linux中提供的套接字接口來連接和通信不同的應(yīng)用程序。在這種編程模型中，應(yīng)用程序可以充當以下兩種角色之一：
1.服務(wù)器：服務(wù)器程序在一個指定的端口監(jiān)聽傳入的連接請求，并處理這些請求。例如，Web服務(wù)器可以監(jiān)聽標準HTTP端口（80），而數(shù)據(jù)庫服務(wù)器可以監(jiān)聽標準MySQL端口（3306）。
2.客戶端：客戶端程序與特定端口上的服務(wù)器建立連接，并向服務(wù)器發(fā)送請求。例如，Web瀏覽器可以通過HTTP協(xié)議與Web服務(wù)器建立連接并獲取網(wǎng)頁，而數(shù)據(jù)庫客戶端可以通過MySQL協(xié)議連接到MySQL服務(wù)器以讀寫數(shù)據(jù)庫。
在Linux套接字編程中，Socket API提供了一組函數(shù)用于創(chuàng)建、綁定、監(jiān)聽、連接和發(fā)送/接收數(shù)據(jù)。以下是一些常用的Socket API函數(shù)：
? socket()：創(chuàng)建一個套接字
? bind()：綁定IP地址和端口號
? listen()：開始監(jiān)聽傳入的連接請求
? accept()：接受傳入的連接請求并返回一個新的套接字
? connect()：與已知IP地址和端口號的主機建立連接
? send()：發(fā)送數(shù)據(jù)到另一個套接字
? recv()：從另一個套接字接收數(shù)據(jù)
掌握Linux套接字編程的技巧
以下是一些掌握Linux套接字編程的技巧，可以幫助開發(fā)人員寫出更高效、更健壯的網(wǎng)絡(luò)應(yīng)用程序。
1.適當設(shè)置套接字選項
在Linux套接字編程中，可以使用setsockopt()函數(shù)設(shè)置套接字選項。下面是一些設(shè)置套接字選項的一些例子：
? SO_REUSEADDR：允許多個套接字綁定相同的IP地址和端口號。
? SO_KEEPALIVE：啟用TCP心跳功能，當連接處于空閑狀態(tài)時，自動發(fā)送心跳包以確保連接處于活動狀態(tài)。
? TCP_NODELAY：禁用Nagle算法，以減少網(wǎng)絡(luò)延遲。
2.使用異步I/O
在Linux套接字編程中，可以使用非阻塞I/O或多路復(fù)用技術(shù)實現(xiàn)異步I/O。異步I/O可以提高應(yīng)用程序的響應(yīng)性和吞吐量。
3.優(yōu)化套接字的緩沖區(qū)
在Linux套接字編程中，可以通過設(shè)置套接字緩沖區(qū)的大小和優(yōu)化讀寫操作來提高網(wǎng)絡(luò)應(yīng)用程序的性能。
4.使用線程或進程池
在高流量環(huán)境中，使用多個線程或進程可以提高網(wǎng)絡(luò)應(yīng)用程序的性能，因為這樣可以并發(fā)地處理來自客戶端的請求。
5.編寫健壯的錯誤處理代碼
在網(wǎng)絡(luò)編程中，錯誤很常見。為了確保程序的健壯性，開發(fā)人員應(yīng)該編寫健壯的錯誤處理代碼，以正確地處理所有可能出現(xiàn)的錯誤情況并恢復(fù)失敗的操作。
結(jié)論
Linux套接字編程是一種強大的網(wǎng)絡(luò)編程技術(shù)，可以用于創(chuàng)建高效、健壯的網(wǎng)絡(luò)應(yīng)用程序。通過掌握Linux套接字編程的基本知識和技巧，開發(fā)人員可以更好地利用這一技術(shù)來實現(xiàn)他們的應(yīng)用程序需求。本文提供的實用提示可以幫助讀者更好地理解和運用Socket API，以創(chuàng)建更高效、更可靠的Linux網(wǎng)絡(luò)應(yīng)用程序。
相關(guān)問題拓展閱讀：
- Linux怎么使用ss命令查看系統(tǒng)的socket狀態(tài)
- Linux中 socket聊天室，給客戶端發(fā)消息
Linux怎么使用ss命令查看系統(tǒng)的socket狀態(tài)
ss是Socket Statistics的縮寫。顧名思義，ss命令可以用來獲取socket統(tǒng)計信息，它可以顯示和netstat類似的內(nèi)容。但ss的優(yōu)勢在于它能夠顯示更多更詳細的有關(guān)TCP和連接狀態(tài)的信息，而且比netstat更快速更高效。當服務(wù)器的socket連接數(shù)量變得非常大時，無論是使用netstat命令還是直接cat /proc/net/tcp，執(zhí)行速度都會很慢?？赡苣悴粫星猩淼母惺?，但請相信我，當服務(wù)器維持的連接達到上萬個的時候，使用netstat等于浪費 生命，而用ss才是節(jié)省時間。天下武功唯快不破。ss快的秘訣在于，它利用到了TCP協(xié)議棧中tcp_diag。tcp_diag是一個用于分析統(tǒng)計的模塊，可以獲得Linux 內(nèi)核中之一手的信息，這就確保了ss的快捷高效。當然，如果你的系統(tǒng)中沒有tcp_diag，ss也可以正常運行，只裂爛是效率會變得稍慢。（但仍然比 netstat要快。）命令格式： ss ［參數(shù)］ ss ［參數(shù)］ ［過濾］.命令功能： ss（Socket Statistics的肆念漏縮寫）命令可以用來獲取 socket統(tǒng)計信息，此命令輸出的結(jié)果類似于 netstat輸出的內(nèi)容，但它能顯示更多更詳細的 TCP連接狀態(tài)的信息，且比 netstat 更快速高效。它使用了 TCP協(xié)議棧中 tcp_diag（是一個用于分析統(tǒng)計的模塊），能直接從獲得之一手內(nèi)核信息，這就使得 ss命令快捷高效。在沒有 tcp_diag，ss也可以正常運行?！? 3.命令參數(shù)： -h， –help 幫助信息 -V， –version 程序版本信息 -n， –numeric 不解析服務(wù)名稱 -r， –resolve 解析主機名 -a， –all 顯示所有套接字（sockets） -l， –listening 顯示監(jiān)聽狀態(tài)的套接字（sockets） -o， –options 顯示計時器信息 -e， –extended 顯示詳細的套接字（sockets）信息 -m， –memory 顯示套接字（socket）的內(nèi)存使用情況 -p， –processes 顯示使用套接字（socket）的進程 -i， –info 顯示 TCP內(nèi)部信息 -s， –summary 顯示套接字（socket）使用概況 -4， –ipv4 僅顯示IPv4的套接字（sockets） -6， –ipv6 僅顯示IPv6的套接字（sockets） -0， –packet 顯示高纖 PACKET 套接字（socket） -t， –tcp 僅顯示 TCP套接字（sockets） -u， –udp 僅顯示 UCP套接字（sockets） -d， –dccp 僅顯示 DCCP套接字（sockets） -w， –raw 僅顯示 RAW套接字（sockets） -x， –unix 僅顯示 Unix套接字（sockets） -f， –family=FAMI 顯示 FAMI類型的套接字（sockets），F(xiàn)AMI可選，支持 unix， inet， inet6， link， netlink -A， –query=QUERY， –socket=QUERY QUERY ：= {allinettcpudprawunixpacketnetlink}［，QUERY］ -D， –diag=FILE 將原始TCP套接字（sockets）信息轉(zhuǎn)儲到文件 -F， –filter=FILE 從文件中都去過濾器信息 FILTER ：= ［ state TCP-STATE ］ ［ EXPRESSION ］ 4.使用實例： 實例1：顯示TCP連接 命令：ss -t -a 輸出： 代碼如下： ［root@localhost ~］# ss -t -a State Recv-Q Send-Q Local Address:Port Peer Address:Port LISTEN.0.0.1:ux *：* LISTEN 0 0 *：3690 *：* LISTEN 0 0 *：ssh *：* ESTAB.168.120.204:ssh 10.2.0.68:［root@localhost ~］# 實例2：顯示 Sockets 摘要 命令：ss -s 輸出： 代碼如下： ?。踨oot@localhost ~］# ss -s Total： 34 （kernel 48） TCP： 4 （estab 1， closed 0， orphaned 0， synrecv 0， timewait 0/0）， ports 3《/p》 《p》Transport Total IP IPv6 *RAWUDPTCPINETFRAG［root@localhost ~］# 說明：列出當前的established， closed， orphaned and waiting TCP sockets 實例3：列出所有打開的網(wǎng)絡(luò)連接端口 命令：ss -l 輸出： 代碼如下： ?。踨oot@localhost ~］# ss -l Recv-Q Send-Q Local Address:Port Peer Address:Port.0.0.1:ux *：**：3690 *：**：ssh *：* ?。踨oot@localhost ~］# 實例4：查看進程使用的socket 命令：ss -pl 輸出： 代碼如下： ［root@localhost ~］# ss -pl Recv-Q Send-Q Local Address:Port Peer Address:Port.0.0.1:ux *：* users：（（“snmpd”，2716，8））*：3690 *：* users：（（“svnserve”，3590，3））*：ssh *：* users：（（“sshd”，2735，3）） ［root@localhost ~］# 實例5：找出打開套接字/端口應(yīng)用程序 命令：ss -lp grep輸出： 代碼如下： ?。踨oot@localhost ~］# ss -lpgrep*：1935 *：* users：（（“fmsedge”，2913，18））.0.0.1:19350 *：* users：（（“fmsedge”，2913，17）） ［root@localhost ~］# ss -lpgrep*：3306 *：* users：（（“mysqld”，2871，10）） ?。踨oot@localhost ~］# 實例6：顯示所有UDP Sockets 命令：ss -u -a 輸出： 代碼如下： ?。踨oot@localhost ~］# ss -u -a State Recv-Q Send-Q Local Address:Port Peer Address:Port UNCONN.0.0.1:syslog *：* UNCONN 0 0 *：snmp *：* ESTAB.168.120.203:.58.119.119:domain ?。踨oot@localhost ~］# 實例7：顯示所有狀態(tài)為established的TP連接 命令：ss -o state established ‘（ dport = ：tp or sport = ：tp ）’ 輸出： 代碼如下： ［root@localhost ~］# ss -o state established ‘（ dport = ：tp or sport = ：tp ）’ Recv-Q Send-Q Local Address:Port Peer Address:Port ?。踨oot@localhost ~］# 實例8：顯示所有狀態(tài)為Established的HTTP連接 命令：ss -o state established ‘（ dport = ：http or sport = ：http ）’ 輸出： 代碼如下： ?。踨oot@localhost ~］# ss -o state established ‘（ dport = ：http or sport = ：http ）’ Recv-Q Send-Q Local Address:Port Peer Address:Port.126.153.214:.168.10.42:http ?。踨oot@localhost ~］# 實例9：列舉出處于 FIN-WAIT-1狀態(tài)的源端口為 80或者 443，目標網(wǎng)絡(luò)為 193.233.7/24所有 tcp套接字 命令：ss -o state fin-wait-1 ‘（ sport = ：http or sport = ：https ）’ dst 193.233.7/24 實例10：用TCP 狀態(tài)過濾Sockets： 命令： 代碼如下： ss -4 state FILTER-NAME-HERE ss -6 state FILTER-NAME-HERE 輸出： 代碼如下： ?。踨oot@localhost ~］#ss -4 state closing Recv-Q Send-Q Local Address:Port Peer Address:Port.126.153.214:http 192.168.10.42:說明： FILTER-NAME-HERE 可以代表以下任何一個： 代碼如下： established syn-sent syn-recv fin-wait-1 fin-wait-2 time-wait closed close-wait last-ack listen closing all ： 所有以上狀態(tài) connected ： 除了listen and closed的所有狀態(tài) synchronized ：所有已連接的狀態(tài)除了syn-sent bucket ： 顯示狀態(tài)為maintained as minisockets，如：time-wait和syn-recv. big ： 和bucket相反?！ 嵗?1：匹配遠程地址和端口號 命令： 代碼如下： ss dst ADDRESS_PATTERN ss dst 192.168.1.5 ss dst 192.168.119.113:http ss dst 192.168.119.113:tp ss dst 192.168.119.113:443 輸出： 代碼如下： ［root@localhost ~］# ss dst 192.168.119.113 State Recv-Q Send-Q Local Address:Port Peer Address:Port ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:ESTAB.168.119.103:.168.119.113:［root@localhost ~］# ss dst 192.168.119.113:http State Recv-Q Send-Q Local Address:Port Peer Address:Port ?。踨oot@localhost ~］# ss dst 192.168.119.113:State Recv-Q Send-Q Local Address:Port Peer Address:Port ESTAB.168.119.103:.168.119.113:［root@localhost ~］# 實例12：匹配本地地址和端口號 命令： 代碼如下： ss src ADDRESS_PATTERN ss src 192.168.119.103 ss src 192.168.119.103:http ss src 192.168.119.103:80 ss src 192.168.119.103:tp ss src 192.168.119.103:25 輸出： 代碼如下： ?。踨oot@localhost ~］# ss src 192.168.119.103:State Recv-Q Send-Q Local Address:Port Peer Address:Port ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.168.119.103:ESTAB.168.119.103:.168.119.201:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:ESTAB.168.119.103:.2.1.206:［root@localhost ~］# 實例13：將本地或者遠程端口和一個數(shù)比較 命令： 代碼如下： ss dport OP PORT ss sport OP PORT 輸出： 代碼如下： ?。踨oot@localhost ~］# ss sport = ：http ?。踨oot@localhost ~］# ss dport = ：http ?。踨oot@localhost ~］# ss dport \》 ：［root@localhost ~］# ss sport \》 ：［root@localhost ~］# ss sport \《 ：［root@localhost ~］# ss sport eq ：22 ?。踨oot@localhost ~］# ss dport ！= ：22 ?。踨oot@localhost ~］# ss state connected sport = ：http ?。踨oot@localhost ~］# ss \（ sport = ：http or sport = ：https \） ?。踨oot@localhost ~］# ss -o state fin-wait-1 \（ sport = ：http or sport = ：https \） dst 192.168.1/24 說明： ss dport OP PORT 遠程端口和一個數(shù)比較；ss sport OP PORT 本地端口和一個數(shù)比較?！ P 可以代表以下任意一個： 《= or le ： 小于或等于端口號 》= or ge ： 大于或等于端口號 == or eq ： 等于端口號 ！= or ne ： 不等于端口號 《 or gt ： 小于端口號 》 or lt ： 大于端口號 實例14：ss 和 netstat 效率對比 命令： 代碼如下： time netstat -at time ss 輸出： 代碼如下： ［root@localhost ~］# time ss real 0m0.739s user 0m0.019s sys 0m0.013s ?。踨oot@localhost ~］# ［root@localhost ~］# time netstat -at real 2m45.907s user 0m0.063s sys 0m0.067s ?。踨oot@localhost ~］# 說明： 用time 命令分別獲取通過netstat和ss命令獲取程序和概要占用資源所使用的時間。在服務(wù)器連接數(shù)比較多的時候，netstat的效率完全沒法和ss比。
Linux中 socket聊天室，給客戶端發(fā)消息
//下面是一個實例
/**
* socket.io chat
*
*/
var web = require(‘QuickWeb’);
// undefined
var _ = undefined;
/**
* 創(chuàng)建一個房間
*
* @param {string} room 房間名稱
* @param {socket.io} io socket.io實例
*/
var Room = module.exports = function (room, io) {
// 初始化socket.io實例，僅在之一次創(chuàng)建房間時需要設(shè)置io參數(shù)
if (typeof io != ‘undefined’)
Room.prototype.io = io;
var io = this.io;
// 房間成員列表
var nicknames = this.nicknames = {};
var onlinesum = this.onlinesum = 0;
// 握手驗證，如果是登錄用戶，則自動獲取其昵稱
io.set(‘a(chǎn)uthorization’, function (handshakeData, callback) {
// 通過客戶端的cookie字符串來獲取其session數(shù)據(jù)
var sessionObject = handshakeData.sessionObject = web.session.getByCookie(handshakeData.headers.cookie);
// 如果不是登錄用戶，則自動為其設(shè)置一個昵稱
var nickname = sessionObject.data.nickname;
if (typeof nickname != ‘string’ || nickname == ”)
nickname = ‘#’ + Math.floor(Math.random() * 1000) + ” + (new Date().getTime() %);
sessionObject.data.nickname = 配帶nickname;
callback(null, true);
});
/** 連接處理 */
var connectionHandle = function (socket) {
onlinesum++;
// 獲取session
var session = socket.handshake.sessionObject.data;
var nickname = session.nickname;
// 保持session，以免session過期
var hold_session = socket.handshake.sessionObject.hold;
/** 刷新在線列表 */
refresh_online = function () {
var n = 辯賣凳;
for (var i in nicknames)
n.push(i);
socket.broadcast.emit(‘online list’, n);
socket.emit(‘online list’, n);
}
// 新成員加入時，通知其他成員
nicknames = socket;
refresh_online();
socket.broadcast.emit(‘system message’, nickname + ‘回來了，大家趕緊去噴他~~’);
/** 公共消息 */
socket.on(‘public message’, function (msg, cb) {
hold_session();
var timestamp = new Date().getTime();
socket.broadcast.emit(‘public message’, nickname, msg, timestamp);
cb();
});
/** 私人消息 */
socket.on(‘private message’, function (to, msg, cb) {
hold_session();
var timestamp = new Date().getTime();
var err = ”;
for (var i in to) {
var target = nicknames>;
if (target) {
cb();
target.emit(‘private message’, nickname, msg, timestamp); 攜旅
}
else {
err += ‘“’ + to + ‘”不在線\n’;
}
}
if (err != ”)
cb(err);
});
/** 斷開來連接 */
socket.on(‘disconnect’, function () {
delete nicknames;
onlinesum–;
socket.broadcast.emit(‘system message’, nickname + ‘悄悄地離開了。。?！?;
refresh_online();
});
/** 命令 */
socket.on(‘command’, function (args, cb) {
if (args.length
#include// 包含套接字函數(shù)庫
#include
#include// 包含AF_INET相關(guān)結(jié)構(gòu)
#include// 包含AF_INET相關(guān)操作的函數(shù)
#include
#include
#include
#include
#include
#define PORT;
#define MYKEY
#define SIZE
int main()
{
int shmid;
char *shmaddr;//定義子進程共用的共享內(nèi)存
shmid = shmget(MYKEY, SIZE, IPC_CREAT | 0600);
shmaddr= (char *) shmat(shmid, 0, 0);
if(shmid==-1)
{
printf(“shmid error\n”);
}
memset(shmaddr,0,SIZE);
int i=0;
char buf;
memset(buf,0,100);
int server_sockfd,client_sockfd;
int server_len,client_len;
struct sockaddr_in server_sockaddr,client_sockaddr;
server_sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定義套接字類型
server_sockaddr.sin_family=AF_INET;
server_sockaddr.sin_port=PORT;
server_sockaddr.sin_addr.s_addr=INADDR_ANY;
server_len=sizeof(server_sockaddr);
//允許重復(fù)使用本地地址和套接字綁定
int j=1;
setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&j,sizeof(j));
//綁定端口
if(bind(server_sockfd,(struct sockaddr *)&server_sockaddr,server_len)==-1)
{
perror(“bind:”);
exit(1);
}
if(listen(server_sockfd,5)==-1)
{
perror(“l(fā)isten:”);
exit(1);
}
printf(“Listening…\n”);
client_len=sizeof(client_sockaddr);
pid_t ppid,pid;
while(1)
{
if((client_sockfd=accept(server_sockfd,(struct sockaddr *)&client_sockaddr,&client_len))==-1)
{
perror(“accept error:”);
exit(1);
}
printf(“%s登錄服務(wù)器\n”,inet_ntoa(client_sockaddr.sin_addr));
ppid=fork();
if(ppid==-1)
{
printf(“fork 1 failed:”);
}
if(ppid==0) //子進程用于接收客戶端信息并發(fā)送
{
pid=fork();
if(pid==-1)
{
printf(“fork 2 failed:”);
exit(1);
}
int recvbytes;
if(pid==0)//子子進程用于接收消息
{
while(1)
{
if((recvbytes=recv(client_sockfd,buf,100,0))==-1)
{
perror(“read client_sockfd failed:”);
}
// printf(“recvbytes=%d\n”,recvbytes);
usleep(10000);
printf(“client send buf=%s\n”,buf);
for(i=0;i0) //子進程用于發(fā)送消息
{
while(1)
{
if(*(shmaddr+i*100)!=0)
{
// strcpy(&buf,shmaddr+100*i);
// buf++;
write(client_sockfd,shmaddr,SIZE);
// send(client_sockfd,buf,strlen(buf),0);
// printf(“the server is send buf=%c”,buf);
// printf(“send client :%s\n”,(shmaddr+i*100)) ;
i++;
}
}
}
}
if(ppid>0)//總父進程返回等待接收消息
{
close(client_sockfd);
}
}
}
客戶端：client.c
#include
#include// 包含套接字函數(shù)庫
#include
#include// 包含AF_INET相關(guān)結(jié)構(gòu)
#include// 包含AF_INET相關(guān)操作的函數(shù)
#include
#include
#include
#define PORT 8888
#define IP_ADDR “192.168.110.185”
#define SIZE 10240
int main()
{
struct tm *timeptr;
time_t timeval;
char tm;
//(void)time(&timeval);
//printf(“the date is %s\n”,ctime(&timeval));
// printf(“The time is %s\n”,tm);
int sockfd; // 用于保存客戶套接字標識符
int len;// 用于客戶消息長度
struct sockaddr_in address; // 定義客戶套接字地址
int result;
sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定義套接字類型
address.sin_family = AF_INET; // 定義套接字地址中的域
address.sin_addr.s_addr = inet_addr(IP_ADDR);// 定義套接字地址
address.sin_port = htons(PORT); // 定義套接字端口
char buf; // 定義要傳送的消息
memset(buf,0,100);
char str;//存貯輸入的語句
char shmaddr; //接受服務(wù)器發(fā)送的全部聊天數(shù)據(jù)
int i=0;
char myname;
char say={“說：”};
printf(“歡迎來到聊天室，請輸入你的姓名:\n”);
scanf(“%s”,myname);
len = sizeof(address);
result = connect(sockfd, (struct sockaddr *) &address, len); // 請求連接
if (result == -1)
{
perror(“Connect failed”);
return 1;
}
printf(“%s成功登錄服務(wù)器:\n”,myname);
pid_t pid;
pid=fork();
if(pid==-1)
{
printf(“fork failed”);
}
int sendbytes=0;
if(pid==0)//子進程用于發(fā)送數(shù)據(jù)
{
while(1)
{
printf(“請輸入語句:\n”);
scanf(“%s”,str);
(void)time(&timeval);
strcpy(tm,ctime(&timeval));
strcpy(buf,myname);//姓名傳入buf中
strcat(buf,tm); //時間傳入buf中
strcat(buf,say);
strcat(buf,str); //語句傳入bufz中
//read(0,buf,strlen(buf));
// send(sockfd,buf,strlen(buf),0);
// getchar();
if((sendbytes=write(sockfd, buf, 100))==-1)
{
perror(“send to server failed:”);
} // 向服務(wù)器傳送消息
// printf(“sendbytes=%d\n”,sendbytes);
// printf(“buf=%s\n”,buf);
// printf(“input buf=%s\n”,buf);
usleep(1000);
memset(buf,0,100);
memset(tm,0,50);
}
}
if(pid>0) //父進程用于接受消息并讀取
{
while(1)
{
read(sockfd,shmaddr,SIZE);
// printf(“server send shmaddr=%s\n”,shmaddr);
if(*(shmaddr+i*100)!=0)
{
printf(“%s\n”,(shmaddr+i*100)) ;
i++;
}
usleep(1000);
}
}
close(sockfd);
return 0;
}
這題目液搜是Linux Socket 很普遍的練習(xí)
你沒貼代碼，不知道問題在哪?
請試試下臘簡面 Server.c and Client.c
服務(wù)器：server.c
#include
#include// 包含套接字函數(shù)庫
#include
#include// 包含AF_INET相關(guān)結(jié)構(gòu)
#include// 包含AF_INET相關(guān)操作的函數(shù)
#include
#include
#include
#include
#include
#define PORT;
#define MYKEY
#define SIZE
int main()
{
int shmid;
char *shmaddr;//定義子進程共用的共享內(nèi)存
shmid = shmget(MYKEY, SIZE, IPC_CREAT | 0600);
shmaddr= (char *) shmat(shmid, 0, 0);
if(shmid==-1)
{
printf(“shmid error\n”);
}
memset(shmaddr,0,SIZE);
int i=0;
char buf;
memset(buf,0,100);
int server_sockfd,client_sockfd;
int server_len,client_len;
struct sockaddr_in server_sockaddr,client_sockaddr;
server_sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定義套接字類型
server_sockaddr.sin_family=AF_INET;
server_sockaddr.sin_port=PORT;
server_sockaddr.sin_addr.s_addr=INADDR_ANY;
server_len=sizeof(server_sockaddr);
//允許重復(fù)使用本地地址和套接字綁定
int j=1;
setsockopt(server_sockfd,SOL_SOCKET,SO_REUSEADDR,&j,sizeof(j));
//綁定端口
if(bind(server_sockfd,(struct sockaddr *)&server_sockaddr,server_len)==-1)
{
perror(“bind:”);
exit(1);
}
if(listen(server_sockfd,5)==-1)
{
perror(“l(fā)isten:”);
exit(1);
}
printf(“Listening…\n”);
client_len=sizeof(client_sockaddr);
pid_t ppid,pid;
while(1)
{
if((client_sockfd=accept(server_sockfd,(struct sockaddr *)&client_sockaddr,&client_len))==-1)
{
perror(“accept error:”);
exit(1);
}
printf(“%s登錄服務(wù)器\n”,inet_ntoa(client_sockaddr.sin_addr));
ppid=fork();
if(ppid==-1)
{
printf(“fork 1 failed:”);
}
if(ppid==0) //子進程用于接收客戶端信息并發(fā)送
{
pid=fork();
if(pid==-1)
{
printf(“fork 2 failed:”);
exit(1);
}
int recvbytes;
if(pid==0)//子子進程用于接收消息
{
while(1)
{
if((recvbytes=recv(client_sockfd,buf,100,0))==-1)
{
perror(“read client_sockfd failed:”);
}
// printf(“recvbytes=%d\n”,recvbytes);
usleep(10000);
printf(“client send buf=%s\n”,buf);
for(i=0;i0) //子進程用于發(fā)送消息
{
while(1)
{
if(*(shmaddr+i*100)!=0)
{
// strcpy(&buf,shmaddr+100*i);
// buf++;
write(client_sockfd,shmaddr,SIZE);
// send(client_sockfd,buf,strlen(buf),0);
// printf(“the server is send buf=%c”,buf);
// printf(“send client :%s\n”,(shmaddr+i*100)) ;
i++;
}
}
}
}
if(ppid>0)//總父進程返回等待接收消息
{
close(client_sockfd);
}
}
}
客戶端：client.c
#include
#include// 包含套接字函數(shù)庫
#include
#include// 包含AF_INET相關(guān)結(jié)構(gòu)
#include// 包含AF_INET相關(guān)操作的函數(shù)
#include
#include
#include
#define PORT 8888
#define IP_ADDR “192.168.110.185”
#define SIZE 10240
int main()
{
struct tm *timeptr;
time_t timeval;
char tm;
//(void)time(&timeval);
//printf(“the date is %s\n”,ctime(&timeval));
// printf(“The time is %s\n”,tm);
int sockfd; // 用于保存客戶套接字標識符
int len;// 用于客戶消息長度
struct sockaddr_in address; // 定義客戶套接字地址
int result;
sockfd = socket(AF_INET,SOCK_STREAM, 0); // 定義套接字類型
address.sin_family = AF_INET; // 定義套接字地址中的域
address.sin_addr.s_addr = inet_addr(IP_ADDR);// 定義套接字地址
address.sin_port = htons(PORT); // 定義套接字端口
char buf; // 定義要傳送的消息
memset(buf,0,100);
char str;//存貯輸入的語句
char shmaddr; //接受服務(wù)器發(fā)送的全部聊天數(shù)據(jù)
int i=0;
char myname;
char say={“說：”};
printf(“歡迎來到聊天室，請輸入你的姓名:\n”);
scanf(“%s”,myname);
len = sizeof(address);
result = connect(sockfd, (struct sockaddr *) &address, len); // 請求連接
if (result == -1)
{
perror(“Connect failed”);
return 1;
}
printf(“%s成功登錄服務(wù)器:\n”,myname);
pid_t pid;
pid=fork();
if(pid==-1)
{
printf(“fork failed”);
}
int sendbytes=0;
if(pid==0)//子進程用于發(fā)送數(shù)據(jù)
{
while(1)
{
printf(“請輸入語句:\n”);
scanf(“%s”,str);
(void)time(&timeval);
strcpy(tm,ctime(&timeval));
strcpy(buf,myname);//姓名傳入buf中
strcat(buf,tm); //時間傳入buf中
strcat(buf,say);
strcat(buf,str); //語句傳入bufz中
//read(0,buf,strlen(buf));
// send(sockfd,buf,strlen(buf),0);
// getchar();
if((sendbytes=write(sockfd, buf, 100))==-1)
{
perror(“send to server failed:”);
} // 向服務(wù)器傳送消息
// printf(“sendbytes=%d\n”,sendbytes);
// printf(“buf=%s\n”,buf);
// printf(“input buf=%s\n”,buf);
usleep(1000);
memset(buf,0,100);
memset(tm,0,50);
}
}
if(pid>0) //父進程用于接受消息并讀取
{
while(1)
{
read(sockfd,shmaddr,SIZE);
// printf(“server send shmaddr=%s\n”,shmaddr);
if(*(shmaddr+i*100)!=0)
{
printf(“%s\n”,(shmaddr+i*100)) ;
i++;
}
usleep(1000);
}
}
close(sockfd);
return 0;
關(guān)于linux socket 使用的介紹到此就結(jié)束了，不知道你從中找到你需要的信息了嗎 ？如果你還想了解更多這方面的信息，記得收藏關(guān)注本站。
成都服務(wù)器租用選創(chuàng)新互聯(lián)，先試用再開通。
創(chuàng)新互聯(lián)（www.cdcxhl.com）提供簡單好用，價格厚道的香港/美國云服務(wù)器和獨立服務(wù)器。物理服務(wù)器托管租用：四川成都、綿陽、重慶、貴陽機房服務(wù)器托管租用。
網(wǎng)站標題：Linux套接字編程指南：掌握Socket使用技巧 (linux socket 使用)
文章鏈接：http://fisionsoft.com.cn/article/dhspcpo.html
