• <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无码专| 国产激情久久久久影院老熟女| 亚洲精品WWW久久久久久| 久久综合噜噜激激的五月天| 久久综合九色综合欧美狠狠| 大香伊人久久精品一区二区 | 亚洲综合久久综合激情久久| 久久se精品一区二区影院 | 精品国产乱码久久久久久1区2区| 成人亚洲欧美久久久久| 色欲综合久久中文字幕网| 91亚洲国产成人久久精品网址| 人人妻久久人人澡人人爽人人精品| 精品国产一区二区三区久久| 久久婷婷五月综合97色直播| 免费精品久久久久久中文字幕| 2022年国产精品久久久久 | 色综合久久88色综合天天| 婷婷五月深深久久精品| 亚洲国产精品狼友中文久久久| 久久精品成人国产午夜| 久久久精品人妻一区二区三区四 | 国产AV影片久久久久久| 国产精品毛片久久久久久久 | 国产成人无码精品久久久久免费 | 久久精品国产亚洲5555| 久久综合久久综合久久综合| 亚洲va久久久噜噜噜久久天堂| 综合久久精品色| 久久91这里精品国产2020| 99久久精品费精品国产| 青青青青久久精品国产h| 亚洲狠狠久久综合一区77777| 久久久久中文字幕| 99久久精品国产综合一区| 久久www免费人成看国产片| 国産精品久久久久久久| 日韩亚洲国产综合久久久|