socket 循環(huán)發(fā)送數(shù)據(jù)，模擬出碼率

liuchang8877

RT，怎么使  服務(wù)端  循環(huán)發(fā)數(shù)據(jù) ，而且還按照一定的周期呢？ 請各位大牛 多多指教。

liuchang8877

比如，怎么實現(xiàn) ，用socke  發(fā)送  800Kbps  ？

liuchang8877

1. #include<stdio.h>
   
2. #include<stdlib.h>
   
3. #include<string.h>
   
4. #include<errno.h>
   
5. #include<sys/types.h>
   
6. #include<sys/socket.h>
   
7. #include<netinet/in.h>
   
8. 
   
9. 
   
10. #define MAXLINE 4096
    
11. 
    
12. int main(int argc,char **argv)
    
13. {
    
14.     int listenfd, connfd;
    
15.     struct sockaddr_in servaddr,cliaddr;
    
16.     char buff[MAXLINE];
    
17.     int n;
    
18. 
    
19.     if((listenfd = socket(AF_INET,SOCK_STREAM,0)) == -1){
    
20.         printf("create socket error: %s(errno: %d)\n", strerror(errno),errno);
    
21.         exit(0);
    
22.     }
    
23. 
    
24.     memset(&servaddr,0,sizeof(servaddr));
    
25.     servaddr.sin_family = AF_INET;
    
26.     servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
    
27.     servaddr.sin_port = htons(20000);
    
28. 
    
29. 
    
30.     if( bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr)) == -1){
    
31.         printf("bind socket error: %s(errno: %d)\n",strerror(errno),errno);
    
32.         exit(0);
    
33.     }
    
34. 
    
35.     if(listen(listenfd,10) == -1){
    
36.         printf("listen socket error:%s(errno:%d)\n",strerror(errno),errno);
    
37.         exit(0);
    
38.     }
    
39. 
    
40. 
    
41.     socklen_t length = sizeof(cliaddr);
    
42.     printf("======waiting for client's request ======= \n");
    
43.     while(1){
    
44.         if( (connfd = accept(listenfd,(struct sockaddr*)&cliaddr,&length)) == -1 ){
    
45. 
    
46.             printf("accept socket error:%s(errno: %d)",strerror(errno),errno);
    
47.             continue;
    
48.         }
    
49. 
    
50.         /* show the child */
    
51.         printf("from client ,IP:%s,PORT:%d\n",inet_ntoa(cliaddr.sin_addr),ntohs(cliaddr.sin_port));
    
52.         memset(&buff,'1',MAXLINE);
    
53. 
    
54.        /*send data*/
    
55.         int size_sockaddr = sizeof(struct sockaddr_in);
    
56. 
    
57.         int i;
    
58.         while(1){  //此處達到了循環(huán)寫入的效果，但是怎可控制寫入的速度？ 用sleep（）/？？
    
59.                for( i = 0; i < 100; i++)
    
60.                      sendto(connfd,buff,MAXLINE,0,(struct sockaddr*)&servaddr,size_sockaddr);
    
61.         }
    
62. //      close(connfd);
    
63.     /*
    
64.     n = recv(connfd,buff,MAXLINE,0);
    
65.     buff[n] = '\0';
    
66.     printf("recv msg from client: %s\n",buff);
    
67.     close(connfd);*/
    
68.    }
    
69.    close(connfd);
    
70.    close(listenfd);
    
71. }
    
72.      
    
73. 
    
74. 
    

復(fù)制代碼

//這是服務(wù)端 發(fā)送 程序，怎么控制它的發(fā)送速率？

liuchang8877

現(xiàn)在出現(xiàn)的是樓上的代碼。為什么會自己退出？？？  奇怪了

liuchang8877

的確和樓上相同，測試出來了，sleep （1）， #define MAXLINE 256   時 是112Kbps ，    #define MAXLINE 512   時 是384Kbps ，    #define MAXLINE 1024   時 是800Kbps ，  #define MAXLINE 2048  時 是1600Kbps .。。  有錯誤的地發(fā) 望高手指正，   覺得這個應(yīng)該跟Pc 有關(guān)，不同的pc 速度不同，是不也會不同？
？？？   

liuchang8877

為啥都不頂我的帖子。。。。。。。。。。新手 默默傷心蹲在墻角