用UDP协议的程序的发送问题

juffun

仿别人程序写的个程序如下，只能一个对一个，所以没有写serve，直接端对端通信，问题是老接不到发出去的消息，包括发给自己的。求大牛指导，万分感谢。代码如下：

1. 
   
2. client.h
   
3. #include <stdio.h>
   
4. #include <string.h>
   
5. #include <stdlib.h>
   
6. #include <sys/types.h>
   
7. #include <sys/socket.h>
   
8. #include <netinet/in.h>
   
9. #include <errno.h>
   
10. #include <semaphore.h>
    
11. #include <unistd.h>
    
12. #include <pthread.h>
    
13. 
    
14. 
    
15. #define PORT 8888
    
16. sem_t send_sem;
    
17. struct sockaddr_in my_addr;
    
18. int sockfd;
    
19. 
    
20. gchar *serv_IP;
    
21. gchar *text;//要发送的文本
    
22. gchar rec_text[1024];//接收到的文本
    
23. 
    
24. GtkTextBuffer *show_buffer,*input_buffer;
    
25. socklen_t len=sizeof(my_addr);
    
26. void show_rec()
    
27. {
    
28.    GtkTextIter start,end;
    
29.     gtk_text_buffer_get_bounds(GTK_TEXT_BUFFER(show_buffer),&start,&end);
    
30.     gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,"他说:\n",8);
    
31.     gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,rec_text,strlen(rec_text)-1);
    
32.     gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,"\n",1);
    
33. }
    
34. void *rec_func(void *arg)
    
35. {
    
36.     while(1)
    
37.     {
    
38.         if(recvfrom(sockfd,rec_text,sizeof(rec_text),0,NULL,&len)<0)
    
39.         {
    
40.             perror("server recv error");
    
41.             exit(1);
    
42.         }
    
43.         fprintf(stdout,"他说 : %s \n",rec_text);
    
44.     }
    
45. }
    
46. 
    
47. void *sen_func(void *arg)
    
48. {
    
49.    
    
50.     while(1)
    
51.     {
    
52.         sem_wait(&send_sem);
    
53.         if(sendto(sockfd,text,sizeof(text),0,(struct sockaddr*)&my_addr,len)==-1)
    
54.         {
    
55.             perror("S send error");
    
56.             exit(1);
    
57.         }
    
58.     }
    
59. }
    
60. 
    
61. void begin_serve()
    
62. {
    
63.    gint res_t;
    
64.    pthread_t rec_pthread,sen_pthread;
    
65.    pthread_attr_t pthread_attr;
    
66.    
    
67.   if((res_t=sem_init(&send_sem,0,0))==-1)
    
68.      {
    
69.      perror("Semaphore init error");
    
70.      exit(EXIT_FAILURE);   
    
71.      }
    
72.    if((sockfd=socket(AF_INET,SOCK_DGRAM,0))==-1)
    
73.     {
    
74.         perror("Socket Error");
    
75.         exit(EXIT_FAILURE);
    
76.     }
    
77.    
    
78.     bzero(&my_addr,sizeof(my_addr));
    
79.     my_addr.sin_family=AF_INET;
    
80.     my_addr.sin_port=htons(PORT);
    
81.    
    
82.    if(inet_pton(AF_INET,serv_IP,&my_addr.sin_addr)<=0)
    
83.     {
    
84.         fprintf(stderr,"IP error\n");
    
85.         exit(1);
    
86.     }
    
87.     if((res_t=pthread_attr_init(&pthread_attr))==-1)
    
88.       {
    
89.       perror("Initiating pthread failed");
    
90.       exit(EXIT_FAILURE);
    
91.       }
    
92.    if((res_t=pthread_attr_setdetachstate(&pthread_attr,PTHREAD_CREATE_DETACHED))==-1)
    
93.       {
    
94.       perror("Setting detached attribute failed");
    
95.       exit(EXIT_FAILURE);
    
96.       }
    
97.   
    
98.    if((res_t=pthread_create(&sen_pthread,&pthread_attr,sen_func,NULL))==-1)
    
99.       {
    
100.       perror("Creating sen_pthread error");
     
101.       exit(EXIT_FAILURE);
     
102.       }
     
103.    if((res_t=pthread_create(&rec_pthread,&pthread_attr,rec_func,NULL))==-1)
     
104.       {
     
105.        perror("Creating rec_pthread error");
     
106.        exit(EXIT_FAILURE);
     
107.       }
     
108.      pthread_attr_destroy(&pthread_attr);
     
109. }
     
110. 
     
111. 以下大部分为GTK的东西，没有什么问题
     
112. #include <gtk/gtk.h>
     
113. #include "client.h"
     
114. 
     
115. void quit_win(GtkWidget *window,gpointer *data)
     
116. {
     
117.   gtk_main_quit();
     
118. }
     
119. 
     
120. 
     
121. void show_text(const gchar* text)
     
122. {
     
123.    GtkTextIter start,end;
     
124.    gtk_text_buffer_get_bounds(GTK_TEXT_BUFFER(show_buffer),&start,&end);
     
125.    gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,"锤锤爷说:\n",13);
     
126.    gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,text,strlen(text));
     
127.    gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,"\n",1);
     
128. }
     
129. 
     
130. void get_IP_func(GtkWidget *widget,gpointer IP_text)
     
131. {
     
132.     GtkTextIter start,end;
     
133.     serv_IP=(gchar *)gtk_entry_get_text(GTK_ENTRY((GtkWidget *)IP_text));//获得IP地址
     
134.     gtk_text_buffer_get_bounds(GTK_TEXT_BUFFER(show_buffer),&start,&end);
     
135.     gtk_text_buffer_insert(GTK_TEXT_BUFFER(show_buffer),&end,"连接成功... \n",17);
     
136.     begin_serve();
     
137. }
     
138. void send_func(GtkWidget *widget,gpointer *data)
     
139. {
     
140.      sem_post(&send_sem);
     
141.      GtkTextIter start,end;
     
142.      gtk_text_buffer_get_bounds(GTK_TEXT_BUFFER(input_buffer),&start,&end);
     
143.      text=(char *)gtk_text_buffer_get_text(GTK_TEXT_BUFFER(input_buffer),&start,&end,FALSE);
     
144.      gtk_text_buffer_delete(GTK_TEXT_BUFFER(input_buffer),&start,&end);
     
145.      show_text(text);
     
146. }
     
147. 
     
148. void clean_func(GtkWidget *widget,gpointer *data)
     
149. {
     
150.      GtkTextIter start,end;
     
151.      gtk_text_buffer_get_bounds(GTK_TEXT_BUFFER(show_buffer),&start,&end);
     
152.      gtk_text_buffer_delete(GTK_TEXT_BUFFER(show_buffer),&start,&end);
     
153.   }
     
154. gint main(gint argc,gchar **argv)
     
155. {
     
156.    GtkWidget *window;
     
157.    GtkWidget *scroll_1,*scroll_2;
     
158.    GtkWidget *send_button,*clean_button,*quit_button,*link_button;
     
159.    GtkWidget *IP_text,*input_text,*show_text;
     
160.    GtkWidget *IP_label,*space_label;
     
161.    GtkWidget *vbox,*hbox;
     
162.    
     
163.    
     
164.    gtk_init(&argc,&argv);
     
165.   
     
166.    window=gtk_window_new(GTK_WINDOW_TOPLEVEL);
     
167.    gtk_window_set_title(GTK_WINDOW(window),"juffun-Chat");
     
168.    gtk_window_set_position(GTK_WINDOW(window),GTK_WIN_POS_CENTER);
     
169.    gtk_window_set_default_size(GTK_WINDOW(window),450,360);
     
170.    
     
171.   
     
172.    send_button=gtk_button_new_with_label("发送");
     
173.    link_button=gtk_button_new_with_label("连接");
     
174.    clean_button=gtk_button_new_with_label("清空");
     
175.    quit_button=gtk_button_new_with_label("关闭");
     
176.    IP_label=gtk_label_new("IP地址：");
     
177.    space_label=gtk_label_new("");
     
178.    
     
179.    IP_text=gtk_entry_new_with_max_length(16);
     
180.    show_text=gtk_text_view_new();
     
181.    input_text=gtk_text_view_new();
     
182. 
     
183.    show_buffer=gtk_text_view_get_buffer(GTK_TEXT_VIEW(show_text));
     
184.    input_buffer=gtk_text_view_get_buffer(GTK_TEXT_VIEW(input_text));
     
185.    
     
186.    gtk_text_view_set_editable(GTK_TEXT_VIEW(show_text),FALSE);
     
187.    
     
188.    scroll_1=gtk_scrolled_window_new(NULL,NULL);
     
189.    scroll_2=gtk_scrolled_window_new(NULL,NULL);
     
190.    gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scroll_1),show_text);
     
191.    gtk_scrolled_window_add_with_viewport(GTK_SCROLLED_WINDOW(scroll_2),input_text);
     
192. 
     
193.    
     
194.    gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scroll_1),GTK_POLICY_AUTOMATIC,GTK_POLICY_AUTOMATIC);
     
195.    gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(scroll_2),GTK_POLICY_AUTOMATIC,GTK_POLICY_AUTOMATIC);
     
196.    
     
197.    vbox=gtk_vbox_new(FALSE,0);
     
198.    hbox=gtk_hbox_new(FALSE,0);
     
199.    
     
200.    gtk_container_add(GTK_CONTAINER(window),vbox);
     
201.    gtk_box_pack_start(GTK_BOX(vbox),scroll_1,TRUE,TRUE,8);
     
202.    gtk_box_pack_start(GTK_BOX(vbox),scroll_2,FALSE,FALSE,2);
     
203.    gtk_box_pack_start(GTK_BOX(hbox),IP_label,FALSE,FALSE,2);
     
204.    gtk_box_pack_start(GTK_BOX(hbox),IP_text,FALSE,FALSE,2);
     
205.    gtk_box_pack_start(GTK_BOX(hbox),link_button,FALSE,FALSE,2);
     
206.    gtk_box_pack_start(GTK_BOX(hbox),space_label,TRUE,TRUE,0);
     
207.    gtk_box_pack_start(GTK_BOX(hbox),clean_button,FALSE,FALSE,2);
     
208.    gtk_box_pack_start(GTK_BOX(hbox),send_button,FALSE,FALSE,2);
     
209.    gtk_box_pack_start(GTK_BOX(hbox),quit_button,FALSE,FALSE,2);
     
210.    gtk_box_pack_start(GTK_BOX(vbox),hbox,FALSE,FALSE,2);
     
211.    
     
212.    g_signal_connect(GTK_OBJECT(window),"destroy",GTK_SIGNAL_FUNC(quit_win),NULL);
     
213.    g_signal_connect(GTK_OBJECT(link_button),"clicked",GTK_SIGNAL_FUNC(get_IP_func),IP_text);
     
214.    g_signal_connect(GTK_OBJECT(clean_button),"clicked",GTK_SIGNAL_FUNC(clean_func),NULL);
     
215.    g_signal_connect(GTK_OBJECT(send_button),"clicked",GTK_SIGNAL_FUNC(send_func),NULL);
     
216.    g_signal_connect(GTK_OBJECT(quit_button),"clicked",GTK_SIGNAL_FUNC(quit_win),NULL);
     
217.    
     
218.    gtk_widget_show_all(window);
     
219.    gtk_main();
     
220.    return 0;
     
221. 
     
222. }
     

复制代码

[ 本帖最后由 juffun 于 2008-7-10 22:54 编辑 ]

linternt

        
        sem_wait(&send_sem);
        if(sendto(sockfd,text,sizeof(text),0,(struct sockaddr*)&my_addr,len)==-1)
        {
            perror("S send error");
            exit(1);
        }

以前遇到过此类问题， socket传输带有\0字符的串会出错， 所以我想您那应该用 strlen(text)

然后您试着把发送前的BUF值以及成功发送的字节数给打出来，方便调试！ 看看能不能找到问题

juffun

谢谢你了，我改成了strlen运行的时候说是段错误了。。。不知道怎么回事

sunorr

my_addr.sin_addr.s_addr = ???

是这个问题吗？没有指定接收IP

blizzard213

bzero(&my_addr,sizeof(my_addr));
    my_addr.sin_family=AF_INET;
// ip!!?
    my_addr.sin_port=htons(PORT);

juffun

if(inet_pton(AF_INET,serv_IP,&my_addr.sin_addr)<=0)
    {
        fprintf(stderr,"IP error\n");
        exit(1);
    }
这个是用于将IP写进去的

juffun

我将sockfd与本机的IP,bind后就可以接收到消息了，不知道为什么？

sunorr

- -#faint，虽然你说的是所谓的端到端，但是还是有一个是做为服务端的，做服务端的时候，是需要绑定一下的。

一般的

UDP编程的服务器端一般步骤是：

1、创建一个socket，用函数socket()；
2、设置socket属性，用函数setsockopt();* 可选
3、绑定IP地址、端口等信息到socket上，用函数bind();
4、循环接收数据，用函数recvfrom();
5、关闭网络连接；


UDP编程的客户端一般步骤是：

1、创建一个socket，用函数socket()；
2、设置socket属性，用函数setsockopt();* 可选
3、绑定IP地址、端口等信息到socket上，用函数bind();* 可选
4、设置对方的IP地址和端口等属性;
5、发送数据，用函数sendto();
6、关闭网络连接；

sunorr

原帖由 juffun 于 2008-7-11 23:17 发表
if(inet_pton(AF_INET,serv_IP,&my_addr.sin_addr)

这个还能这样用啊～，呵呵。学到了～