• <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>

            不會飛的鳥

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

            posted on 2011-07-03 13:56 不會飛的鳥 閱讀(230) 評論(0)  編輯 收藏 引用


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


            久久精品夜色噜噜亚洲A∨ | 热久久国产精品| 精品国产乱码久久久久久郑州公司| 久久天天躁狠狠躁夜夜avapp| 国产精品9999久久久久| 91麻精品国产91久久久久| 欧美激情精品久久久久久久| 久久久国产打桩机| 97r久久精品国产99国产精| 99热成人精品免费久久| 午夜精品久久久久| 欧美牲交A欧牲交aⅴ久久| 9999国产精品欧美久久久久久 | 久久影视国产亚洲| 亚洲av伊人久久综合密臀性色| 久久亚洲精品中文字幕三区| 日本精品久久久久久久久免费| 午夜精品久久久久久久| 久久久久久免费一区二区三区| 亚洲国产成人久久综合一区77 | 亚洲精品白浆高清久久久久久| 久久电影网2021| 亚洲国产成人久久精品99 | 欧美亚洲另类久久综合| 色播久久人人爽人人爽人人片aV | 精品久久久久久久久久中文字幕| 国产精品久久久久久五月尺| 久久婷婷久久一区二区三区| 欧美日韩精品久久久免费观看| 免费观看久久精彩视频| 无码国产69精品久久久久网站| 久久综合九色欧美综合狠狠| 精品午夜久久福利大片| 久久精品国产免费观看三人同眠| 国产亚洲美女精品久久久| 精品无码久久久久国产| 亚洲中文精品久久久久久不卡 | 中文字幕成人精品久久不卡| 亚洲中文字幕无码一久久区| 亚洲一区精品伊人久久伊人| 国产精品成人99久久久久|