chinese直男口爆体育生外卖, 99久久er热在这里只有精品99, 又色又爽又黄18禁美女裸身无遮挡, gogogo高清免费观看日本电视,私密按摩师高清版在线,人妻视频毛茸茸,91论坛 兴趣闲谈,欧美 亚洲 精品 8区,国产精品久久久久精品免费

0
  • 聊天消息
  • 系統(tǒng)消息
  • 評論與回復
登錄后你可以
  • 下載海量資料
  • 學習在線課程
  • 觀看技術(shù)視頻
  • 寫文章/發(fā)帖/加入社區(qū)
會員中心
創(chuàng)作中心

完善資料讓更多小伙伴認識你,還能領(lǐng)取20積分哦,立即完善>

3天內(nèi)不再提示

Linux開發(fā)_采用線程處理網(wǎng)絡(luò)請求

DS小龍哥-嵌入式技術(shù) ? 2022-09-17 15:21 ? 次閱讀
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

【摘要】 介紹Linux下網(wǎng)絡(luò)編程、線程編程,select機制,利用子線程響應(yīng)TCP服務(wù)器的請求。

??TCP服務(wù)器創(chuàng)建流程:

1.?創(chuàng)建套接字

2.?綁定IP地址和端口號(創(chuàng)建服務(wù)器)

3.?設(shè)置監(jiān)聽的數(shù)量(限制最大可以連接的客戶端數(shù)量)

4.?等待客戶端連接

5.?實現(xiàn)基本通信

??TCP客戶端創(chuàng)建流程

1.?創(chuàng)建套接字

2.?連接服務(wù)器

3.?實現(xiàn)基本通信

任務(wù)1:網(wǎng)絡(luò)編程

練習:

1.?實現(xiàn)TCP服務(wù)器與TCP客戶端之間的基本通信,收發(fā)數(shù)據(jù) (按照上課的思路流程看函數(shù)文檔)

2.?實現(xiàn)TCP服務(wù)器與TCP客戶端之間的文件傳輸。(單個文件傳輸)

驗證方式:(1) 同一臺電腦演示 (2)同桌之間演示

考慮的問題:

(1)?網(wǎng)絡(luò)的傳輸環(huán)境,考慮應(yīng)答問題

(2)?數(shù)據(jù)丟包之后如何處理? 可以重發(fā)

(3)?超時處理

(4)?服務(wù)器與客戶端之間連接斷開處理。(客戶端和服務(wù)器兩邊都需要重新連接)

文件傳輸可以在廣告機中使用。

(擴展要求): 顯示接收進度百分比,顯示接收的文件名稱,推薦: 定義結(jié)構(gòu)體(使用數(shù)據(jù)結(jié)構(gòu))

3.?(擴展)實現(xiàn)TCP服務(wù)器與TCP客戶端之間的目錄傳輸。

4.?(擴展)實現(xiàn)網(wǎng)絡(luò)聊天室(模仿QQ發(fā)送消息的效果)

??一般情況下,推薦最大每次傳輸?shù)淖止?jié)數(shù)不超過1024字節(jié)。

任務(wù)2:線程編程

#include

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,

void *(*start_routine) (void *), void *arg);

Compile and link with -pthread.

-lpthread

理解: 一個線程就是一個while(1)。

[root@wbyq linux-share-dir]# gcc app.c

/tmp/cccOs4TK.o: In function `main':

app.c:(.text+0x69): undefined reference to `pthread_create'

app.c:(.text+0x8d): undefined reference to `pthread_create'

collect2: ld 返回 1

[root@wbyq linux-share-dir]# gcc app.c -lpthread

練習:

1.?學習線程的基本使用

#include 
#include 
void *start_1(void *arg)
{
	while(1)
	{
		printf("123\n");
		sleep(1);
	}
}

void *start_2(void *arg)
{
	while(1)
	{
		printf("456\n");
		sleep(1);
	}
}

int main(int argc,char *argv[])
{
	pthread_t thread_1;
	pthread_t thread_2;
	pthread_create(&thread_1,NULL,start_1,NULL);
	pthread_create(&thread_2,NULL,start_2,NULL);
	while(1)
	{
		printf("789\n");
		sleep(1);
	}
	return 0;
}

2.?實現(xiàn)一個服務(wù)器實現(xiàn)多個客戶端的連接,實現(xiàn)通信。

思路: 一個客戶端就是一個獨立的線程。

3.?擴展練習: 實現(xiàn)服務(wù)器同時對多個客戶端進行文件發(fā)送。

(1)?服務(wù)器連接上一個客戶端就創(chuàng)建一個線程。

(2)?線程的函數(shù)需要寫幾個? 1個

1個函數(shù)需要考慮的問題: 函數(shù)的可重入性能!

需要考慮到資源搶占! 使用信號量!

(搶答器)

設(shè)置線程分離屬性:

#include 
#include 
char str1[]="123456";
char str2[]="abcdef";
void *start_1(void *arg)
{
	 printf("arg1=%s\n",arg);
	 sleep(1);
}

void *start_2(void *arg)
{
	printf("arg2=%s\n",arg);
	sleep(2);
}
int main(int argc,char *argv[])
{
	pthread_t thread_1;
	pthread_t thread_2;
	pthread_create(&thread_1,NULL,start_1,"線程1的參數(shù)傳遞測試");
	pthread_create(&thread_2,NULL,start_2,"線程2的參數(shù)傳遞測試");
	
	pthread_detach(thread_1); //設(shè)置線程的分離屬性
	pthread_detach(thread_2); //設(shè)置線程的分離屬性
	
	while(1)
	{
		
	}
	return 0;
}

任務(wù)3: select阻塞輪詢機制

(1)?服務(wù)器什么時候收到數(shù)據(jù)? read

(2)?客戶端什么時候收到數(shù)據(jù)? Read

(3)?客戶端如何判斷已經(jīng)與服務(wù)器斷開連接?

使用select機制 ,當select函數(shù)返回值為1,read函數(shù)為0就表示斷開

(4)?服務(wù)器如何檢測客戶端已經(jīng)斷開連接?

采用心跳包的模式: 規(guī)定客戶端每5秒鐘發(fā)送一個特定的數(shù)據(jù)給服務(wù)器。

??IO 多路復用是指內(nèi)核一旦發(fā)現(xiàn)進程指定的一個或者多個 IO 條件準備讀取,它就通知該進程。

IO 條件:

(1)?網(wǎng)絡(luò)編程中的讀寫

(2)?標準輸出輸入中的讀寫

#include 

#include 

#include 

#include 
select:同時可以監(jiān)控多個文件描述符。
int select(int nfds, fd_set *readfds, fd_set *writefds,fd_set *exceptfds, struct timeval *timeout);

參數(shù):

int nfds :最大的文件描述符+1

fd_set *readfds :讀事件發(fā)生

fd_set *writefds :寫事件發(fā)生

fd_set *exceptfds:出現(xiàn)問題

struct timeval *timeout:輪詢的時間。

填NULL表示無限阻塞。

結(jié)構(gòu)體里的成員填0,表示不阻塞

結(jié)構(gòu)體里的成員填>0,正常的阻塞時間

返回值: 0表示沒有任何事件發(fā)生,負數(shù)表示失敗。>0表示發(fā)生對應(yīng)的事件。
void FD_CLR(int fd, fd_set *set); //清除指定文件描述符

int FD_ISSET(int fd, fd_set *set); //檢測指定的文件描述符是否發(fā)生了事件

void FD_SET(int fd, fd_set *set); //添加指定的文件描述符到fd描述符集合(多次調(diào)用)

void FD_ZERO(fd_set *set); //清除整個文件描述符集合
struct timeval {

long tv_sec; /* seconds */

long tv_usec; /* microseconds */

};

TCP服務(wù)器端處理:

#include 
#include           /* See NOTES */
#include 
#include    //使用大小端轉(zhuǎn)換函數(shù)
#include 
#include 
#include 
#include 
#include 
#include 
//函數(shù)聲明
void *start_routine_1(void *dev);
void *start_routine_2(void *dev);

typedef void *(*start_routine) (void *);
start_routine fun[]={start_routine_1,start_routine_2};
pthread_t thread_id[2];                //存放線程的標識符
int clientfd[2];                       //保存TCP客戶端的網(wǎng)絡(luò)套接字
struct sockaddr_in client_address[2];  //存放客戶端的信息
socklen_t address_len[2];              //存放客戶端結(jié)構(gòu)體信息的長度
/*服務(wù)器端口號定義*/
#define P_host 8080

/*TCP服務(wù)器代碼*/
int main(int argc,char *argv[])
{
	 int socketfd;
	 struct sockaddr_in server_address;     //存放服務(wù)器的IP地址信息
	 
   memset(&server_address,0,sizeof(struct sockaddr_in)); //初始化內(nèi)存空間
   memset(client_address,0,sizeof(struct sockaddr_in)*2); //初始化內(nèi)存空間
   
	 server_address.sin_family=PF_INET;            //IPV4協(xié)議
	 server_address.sin_port=htons(P_host);        //端口號賦值
	 server_address.sin_addr.s_addr=INADDR_ANY;    //本地IP地址
  /*1 .創(chuàng)建套接字*/
   socketfd=socket(PF_INET,SOCK_STREAM,0);
   if(socketfd<0)
   	{
   	    printf("服務(wù)器網(wǎng)絡(luò)套接字創(chuàng)建失敗!\n");	
   	    return -1;
   	}
      	 
   /*2. 綁定端口,創(chuàng)建服務(wù)器*/
   if(bind(socketfd,(const struct sockaddr *)&server_address,sizeof(struct sockaddr))!=0)
   	{
   	    printf("服務(wù)器綁定端口失敗!\n");	
   	    return -1; 	
   	}
   
   /*3. 設(shè)監(jiān)聽的端口數(shù)量*/
   if(listen(socketfd,10)!=0)
   	{
   		 printf("服務(wù)器端口監(jiān)聽失敗!\n");	
   	   return -1;	 
   	}
   
    int i;
    
    for(i=0;i<2;i++)
   	{
   		 address_len[i]=sizeof(struct sockaddr);  //計算結(jié)構(gòu)體大小 20 
   	  /*4. 等待客戶端連接*/
	    if((clientfd[i]=accept(socketfd,(struct sockaddr *)&client_address[i],&address_len[i]))<0)
	   	{
	   	   	printf("等待客戶端連接失敗!\n");	
	   	    break;	
	   	} 
	    
	    //創(chuàng)建線程
	   	if(pthread_create(&thread_id[i],NULL,fun[i],NULL)!=0)
			{
			   printf("線程_%d_創(chuàng)建失敗!\n",i);		
			} 	
   	}
   	
   	while(1)
   	{
   	    	
   	}
     	
   //阻塞方式等待線程的結(jié)束
	pthread_join(thread_id[0],NULL);
	pthread_join(thread_id[1],NULL);
	return 0;	
}
//線程1
void *start_routine_1(void *dev)
{
	 while(1)
	 {
	 	  printf("TCP客戶端1連接!\n");
	 	  sleep(2);
	 }
	 //終止線程
	 pthread_exit(NULL);
}
//線程2
void *start_routine_2(void *dev)
{
	while(1)
	{
	 	  printf("TCP客戶端2連接!\n");
	 	  sleep(2);
	}
	 //終止線程
	 pthread_exit(NULL);
}
聲明:本文內(nèi)容及配圖由入駐作者撰寫或者入駐合作網(wǎng)站授權(quán)轉(zhuǎn)載。文章觀點僅代表作者本人,不代表電子發(fā)燒友網(wǎng)立場。文章及其配圖僅供工程師學習之用,如有內(nèi)容侵權(quán)或者其他違規(guī)問題,請聯(lián)系本站處理。 舉報投訴
  • Linux
    +關(guān)注

    關(guān)注

    88

    文章

    11576

    瀏覽量

    216636
  • 編程
    +關(guān)注

    關(guān)注

    89

    文章

    3704

    瀏覽量

    96258
  • 線程
    +關(guān)注

    關(guān)注

    0

    文章

    508

    瀏覽量

    20653
收藏 人收藏
加入交流群
微信小助手二維碼

掃碼添加小助手

加入工程師交流群

    評論

    相關(guān)推薦
    熱點推薦

    創(chuàng)龍 瑞芯微 RK3588 國產(chǎn)2.4GHz八核 工業(yè)開發(fā)板—Linux-RT應(yīng)用開發(fā)案例

    Linux-RT 性能;還提供 rt_gpio_ctrl(實時線程控制 LED 翻轉(zhuǎn))、rt_input(實時線程監(jiān)聽按鍵觸發(fā) LED)兩個開發(fā)案例,含測試、編譯步驟與關(guān)鍵代碼,為評
    的頭像 發(fā)表于 09-25 17:25 ?316次閱讀
    創(chuàng)龍 瑞芯微 RK3588 國產(chǎn)2.4GHz八核 工業(yè)<b class='flag-5'>開發(fā)</b>板—<b class='flag-5'>Linux</b>-RT應(yīng)用<b class='flag-5'>開發(fā)</b>案例

    NVMe高速傳輸之擺脫XDMA設(shè)計29: TLP 請求處理流程

    請求類型為 MEM 讀寫請求時使用地址路由的方式。 如果請求地址在此設(shè)備 BAR 空間內(nèi), 則對 BAR 空間進行讀寫操作,讀操作將生成 CplD, 從對應(yīng)請求端口的輸出端口發(fā)出;
    的頭像 發(fā)表于 09-23 09:05 ?293次閱讀
    NVMe高速傳輸之擺脫XDMA設(shè)計29: TLP <b class='flag-5'>請求</b><b class='flag-5'>處理</b>流程

    網(wǎng)絡(luò)接收線程erxmb異常的原因?怎么解決?

    兩個不同的軟件接收組播數(shù)據(jù)久了后均出現(xiàn)網(wǎng)絡(luò)數(shù)據(jù)無法接收,網(wǎng)絡(luò)發(fā)送是正常的。lpc54628芯片。郵箱有8個但erxmb線程已經(jīng)無法運行了,這是什么原因?qū)е?/div>
    發(fā)表于 09-15 08:06

    【HZ-T536開發(fā)板免費體驗】—— linux創(chuàng)建線程

    任務(wù),并行是多個處理器或多核處理器同時執(zhí)行不同的任務(wù)。 Linux系統(tǒng)中進行多線程編程時,會涉及到主線程和子
    發(fā)表于 09-01 21:31

    Linux 應(yīng)用開發(fā)手冊

    T507linux應(yīng)用開發(fā)手冊
    發(fā)表于 08-22 17:01 ?2次下載

    NVMe高速傳輸之擺脫XDMA設(shè)計之12:PCIe請求模塊設(shè)計(上)

    TLP發(fā)送。由于請求時序不沖突,采用單條內(nèi)部總線處理多模塊請求。所有請求數(shù)據(jù)長度固定為32位雙字。更多性能信息可參考B站用戶名:專注與守望
    的頭像 發(fā)表于 08-04 09:52 ?455次閱讀
    NVMe高速傳輸之擺脫XDMA設(shè)計之12:PCIe<b class='flag-5'>請求</b>模塊設(shè)計(上)

    5分鐘學會網(wǎng)絡(luò)服務(wù)搭建!飛凌i.MX9352開發(fā)板 + Linux 6.1實戰(zhàn)示例

    本文就將以飛凌嵌入式OK-MX9352-C開發(fā)板(搭載了在工業(yè)物聯(lián)網(wǎng)領(lǐng)域廣泛應(yīng)用的NXP i.MX9352處理器)為平臺,介紹如何在Linux6.1.36開發(fā)環(huán)境當中如何搭建常用的
    的頭像 發(fā)表于 06-13 16:42 ?974次閱讀
    5分鐘學會<b class='flag-5'>網(wǎng)絡(luò)</b>服務(wù)搭建!飛凌i.MX9352<b class='flag-5'>開發(fā)</b>板 + <b class='flag-5'>Linux</b> 6.1實戰(zhàn)示例

    摩爾線程Linux驅(qū)動v3.0.0發(fā)布

    近日,摩爾線程正式推出Linux驅(qū)動程序v3.0.0,全面支持圖形顯卡MTT S80和高性能專業(yè)顯卡MTT X300。作為v2.7.0RC4之后的重大升級版本,本次更新實現(xiàn)了多項關(guān)鍵技術(shù)突破:在架構(gòu)
    的頭像 發(fā)表于 05-08 11:38 ?955次閱讀
    摩爾<b class='flag-5'>線程</b><b class='flag-5'>Linux</b>驅(qū)動v3.0.0發(fā)布

    Linux主要的性能有哪些?

    ? 什么是Linux? ? Linux是一套自由傳播的類Unix操作系統(tǒng),是一個基于posix和unix的多用戶、多任務(wù)、支持多線程和多cpu的操作系統(tǒng)。它的基本思想有兩點,一切都是文件和每個軟件
    的頭像 發(fā)表于 04-30 18:09 ?394次閱讀
    <b class='flag-5'>Linux</b>主要的性能有哪些?

    Linux網(wǎng)絡(luò)設(shè)置與基礎(chǔ)服務(wù)

    Linux網(wǎng)絡(luò)設(shè)置與基礎(chǔ)服務(wù)
    的頭像 發(fā)表于 04-09 11:51 ?2963次閱讀
    <b class='flag-5'>Linux</b><b class='flag-5'>網(wǎng)絡(luò)</b>設(shè)置與基礎(chǔ)服務(wù)

    [迅為]Linux開發(fā)小技巧:Remote - SSH插件

    [迅為]Linux開發(fā)小技巧:Remote - SSH插件
    的頭像 發(fā)表于 04-01 15:46 ?757次閱讀
    [迅為]<b class='flag-5'>Linux</b><b class='flag-5'>開發(fā)</b>小技巧:Remote - SSH插件

    服務(wù)器如何處理 HTTP 請求

    服務(wù)器處理HTTP請求的過程是一個有序且復雜的流程,通常涉及多個步驟。以下是服務(wù)器處理HTTP請求的具體步驟: 監(jiān)聽端口 :HTTP服務(wù)器在特定的端口(通常是80端口,除非另有指定)上
    的頭像 發(fā)表于 12-30 09:37 ?898次閱讀

    如何調(diào)試 HTTP 請求和響應(yīng)

    調(diào)試HTTP請求和響應(yīng)是Web開發(fā)網(wǎng)絡(luò)編程中的一個重要技能。以下是一些步驟和工具,可以幫助你調(diào)試HTTP請求和響應(yīng): 1. 使用瀏覽器開發(fā)
    的頭像 發(fā)表于 12-30 09:28 ?1659次閱讀

    socket 多線程編程實現(xiàn)方法

    在現(xiàn)代網(wǎng)絡(luò)編程中,多線程技術(shù)被廣泛應(yīng)用于提高服務(wù)器的并發(fā)處理能力。Socket編程是網(wǎng)絡(luò)通信的基礎(chǔ),而將多線程技術(shù)應(yīng)用于Socket編程,可
    的頭像 發(fā)表于 11-12 14:16 ?1337次閱讀

    Python編程:處理網(wǎng)絡(luò)請求的代理技術(shù)

    網(wǎng)絡(luò)編程中,代理技術(shù)扮演著至關(guān)重要的角色,尤其在處理網(wǎng)絡(luò)請求時。通過代理服務(wù)器,我們可以實現(xiàn)請求的轉(zhuǎn)發(fā)、緩存、負載均衡以及安全控制等功能。
    的頭像 發(fā)表于 11-12 07:23 ?761次閱讀