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