• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            不會(huì)飛的鳥

            2010年12月10日 ... 不鳥他們!!! 我要用自己開發(fā)的分布式文件系統(tǒng)、分布式調(diào)度系統(tǒng)、分布式檢索系統(tǒng), 做自己的搜索引擎!!!大魚有大志?。?! ---楊書童

            基于UDP協(xié)議的網(wǎng)絡(luò)程序

             

            下圖是典型的UDP客戶端/服務(wù)器通訊過程。

             UDP通訊流程

            UDP通訊流程

            以下是簡單的UDP服務(wù)器和客戶端程序。

            /* server.c */
            #include 
            <stdio.h>
            #include 
            <string.h>
            #include 
            <netinet/in.h>
            #include 
            "wrap.h"

            #define MAXLINE 80
            #define SERV_PORT 8000

            int main(void)
            {
                
            struct sockaddr_in servaddr, cliaddr;
                socklen_t cliaddr_len;
                
            int sockfd;
                
            char buf[MAXLINE];
                
            char str[INET_ADDRSTRLEN];
                
            int i, n;

                sockfd 
            = Socket(AF_INET, SOCK_DGRAM, 0);

                bzero(
            &servaddr, sizeof(servaddr));
                servaddr.sin_family 
            = AF_INET;
                servaddr.sin_addr.s_addr 
            = htonl(INADDR_ANY);
                servaddr.sin_port 
            = htons(SERV_PORT);
                
                Bind(sockfd, (
            struct sockaddr *)&servaddr, sizeof(servaddr));

                printf(
            "Accepting connections \n");
                
            while (1{
                    cliaddr_len 
            = sizeof(cliaddr);
                    n 
            = recvfrom(sockfd, buf, MAXLINE, 0, (struct sockaddr *)&cliaddr, &cliaddr_len);
                    
            if (n == -1)
                        perr_exit(
            "recvfrom error");
                    printf(
            "received from %s at PORT %d\n",
                           inet_ntop(AF_INET, 
            &cliaddr.sin_addr, str, sizeof(str)),
                           ntohs(cliaddr.sin_port));
                
                    
            for (i = 0; i < n; i++)
                        buf[i] 
            = toupper(buf[i]);
                    n 
            = sendto(sockfd, buf, n, 0, (struct sockaddr *)&cliaddr, sizeof(cliaddr));
                    
            if (n == -1)
                        perr_exit(
            "sendto error");
                }

            }

            /* client.c */
            #include 
            <stdio.h>
            #include 
            <string.h>
            #include 
            <unistd.h>
            #include 
            <netinet/in.h>
            #include 
            "wrap.h"

            #define MAXLINE 80
            #define SERV_PORT 8000

            int main(int argc, char *argv[])
            {
                
            struct sockaddr_in servaddr;
                
            int sockfd, n;
                
            char buf[MAXLINE];
                
            char str[INET_ADDRSTRLEN];
                socklen_t servaddr_len;
                
                sockfd 
            = Socket(AF_INET, SOCK_DGRAM, 0);

                bzero(
            &servaddr, sizeof(servaddr));
                servaddr.sin_family 
            = AF_INET;
                inet_pton(AF_INET, 
            "127.0.0.1"&servaddr.sin_addr);
                servaddr.sin_port 
            = htons(SERV_PORT);
                
                
            while (fgets(buf, MAXLINE, stdin) != NULL) {
                    n 
            = sendto(sockfd, buf, strlen(buf), 0, (struct sockaddr *)&servaddr, sizeof(servaddr));
                    
            if (n == -1)
                        perr_exit(
            "sendto error");

                    n 
            = recvfrom(sockfd, buf, MAXLINE, 0, NULL, 0);
                    
            if (n == -1)
                        perr_exit(
            "recvfrom error");
                  
                    Write(STDOUT_FILENO, buf, n);
                }


                Close(sockfd);
                
            return 0;
            }

            由于UDP不需要維護(hù)連接,程序邏輯簡單了很多,但是UDP協(xié)議是不可靠的,實(shí)際上有很多保證通訊可靠性的機(jī)制需要在應(yīng)用層實(shí)現(xiàn)。

            編譯運(yùn)行server,在兩個(gè)終端里各開一個(gè)client與server交互,看看server是否具有并發(fā)服務(wù)的能力。用Ctrl+C關(guān)閉server,然后再運(yùn)行server,看此時(shí)client還能否和server聯(lián)系上。和前面TCP程序的運(yùn)行結(jié)果相比較,體會(huì)無連接的含義。

            posted on 2011-07-03 13:56 不會(huì)飛的鳥 閱讀(246) 評(píng)論(0)  編輯 收藏 引用


            只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            久久精品午夜一区二区福利| 人妻丰满AV无码久久不卡| 国产精品免费福利久久| 一本一道久久a久久精品综合| 9191精品国产免费久久| 久久99国产精一区二区三区| 精品无码久久久久国产| 久久福利青草精品资源站| 久久九九有精品国产23百花影院| 无遮挡粉嫩小泬久久久久久久 | 国产精品美女久久久| 久久久久亚洲Av无码专| 国产一区二区三区久久精品| 久久精品亚洲中文字幕无码麻豆| 久久大香香蕉国产| 午夜不卡888久久| 久久久久无码专区亚洲av| 亚洲人AV永久一区二区三区久久| 日日狠狠久久偷偷色综合96蜜桃| 久久91亚洲人成电影网站| 亚洲国产精品久久久久婷婷软件| 99久久国产综合精品五月天喷水| 韩国三级中文字幕hd久久精品| 国产一区二区精品久久凹凸| 久久婷婷五月综合97色直播| 久久亚洲AV无码精品色午夜 | 色成年激情久久综合| 国产三级观看久久| 亚洲午夜无码久久久久| 精品国产91久久久久久久| 欧美麻豆久久久久久中文| 久久久噜噜噜www成人网| 久久精品国产第一区二区| 伊人久久大香线蕉av不变影院| 狠狠色丁香久久综合五月| 伊人精品久久久久7777| 久久精品国产亚洲精品2020| 久久久久免费视频| 精品免费tv久久久久久久| 国产精品中文久久久久久久| 久久精品国产只有精品2020|