進(jìn)程間同步和通信-資料下載頁
2024-10-11 08:43本頁面
【導(dǎo)讀】Unix系統(tǒng)提供的基本的IPC包括：。管道是半雙工的，數(shù)據(jù)只能向一個(gè)方向流動(dòng)；寫入的內(nèi)容每次都添加在管道緩沖區(qū)的末尾，每次都是從緩沖區(qū)的頭部讀出數(shù)據(jù)。需要雙方通信時(shí)，需要建立起兩個(gè)管道；命令1把ls的輸出重定向到tmp文件中；管道可看成是被打開的文件，但并沒有真實(shí)的。pipe()系統(tǒng)調(diào)用用來創(chuàng)建一個(gè)新的管道。管道兩端的功能是固定的：。filedes[1]只能用于寫，稱為管道寫端。若試圖從寫端讀，或者向讀端寫都將導(dǎo)致錯(cuò)誤發(fā)生。管道只能在具有親緣關(guān)系的進(jìn)程之間進(jìn)行通信。通過fork傳遞管道的描述符。任意的兩個(gè)進(jìn)程不可能共享同一個(gè)管道。管道的一個(gè)重大限制是它沒有名字，因此。有名管道提出后，該限制得到了克服。及特定的優(yōu)先級。根據(jù)給定的鍵值，返回對應(yīng)的消息隊(duì)列。對于發(fā)送消息來講，msgflg有意義的標(biāo)志為。求的msgsz字節(jié)，則把該消息截?cái)?，截?cái)嗖糠謱G失。消息隊(duì)列的其他操作。對由msqid標(biāo)識的消息隊(duì)列執(zhí)行cmd操作：。同時(shí)，也影響msg_ctime成員。獲得信號量集描述符。IPC_NOWAIT：當(dāng)期望的操作無法完成時(shí)，直接返回
【正文】 ind(sd, (struct sockaddr *) amp。my_addr, sizeof(struct sockaddr))。 bind填寫了服務(wù)器的地址和端口信息，最大的端口值為 65535 Embedded Operating Systems 32 服務(wù)器調(diào)用 listen設(shè)置偵聽 ? 第二個(gè)參數(shù)指定最多客戶數(shù) listen(sd,5)。 ? listen將立即返回 Embedded Operating Systems 33 服務(wù)器調(diào)用 accept接收客戶連接請求 sin_size = sizeof(struct sockaddr_in)。 newsd = accept(sd, amp。their_addr, amp。sin_size)。 ? Accept將會(huì) blocking直到有客戶連接 ? 返回與客戶端相關(guān)的 newsd，并將客戶端的信息存放在 their_addr中 Embedded Operating Systems 34 TCP服務(wù)器編程模型 socket(...)。 bind(...)。 listen(...)。 while(1) //循環(huán)服務(wù)器 { accept(...)。 while(1) { read(...)。 process(...)。 write(...)。 } close(...)。 } Embedded Operating Systems 35 客戶端調(diào)用 connect請求連接 ? 在 serv_addr中指明要連接的服務(wù)器地址和端口 ? 成功以后，就可以進(jìn)行 send/recv或者read/write了 Embedded Operating Systems 36 struct sockaddr_in dest_addr。 sd = socket(AF_INET, SOCK_STREAM, 0)。 bzero(amp。(dest_addr),sizeof(struct addr_in))。 = AF_INET。 = htons(DEST_PORT)。 = i_addr(DEST_IP)。 connect(sd, (struct sockaddr *)amp。dest_addr, sizeof(struct sockaddr))。 Embedded Operating Systems 37 TCP客戶端編程模型 socket(…) connect(…) while(1) { read(…) … write(…) } close(…)
教學(xué)課件相關(guān)推薦
鄂ICP備17016276號-1