C/S模式的GTK聊天程序，C语言编写，运行不出结果，跪求指教~~

mybooks_zzz

1. #include<glib.h>
   
2. #include<stdio.h>
   
3. #include<fcntl.h>
   
4. #include<signal.h>
   
5. #include<sys/socket.h>
   
6. #include<sys/types.h>
   
7. #include<sys/time.h>
   
8. #include<unistd.h>
   
9. #include<netdb.h>
   
10. #include<netinet/in.h>
    
11. 
    
12. 
    
13. #define OURPORT 8088
    
14. #define MAX_USERS 8
    
15. 
    
16. struct _client{
    
17.         gint sd;
    
18.         gboolean in_use;
    
19.         gchar name[64];
    
20.         gchar buf[1024];
    
21. };
    
22. typedef struct _client client;
    
23. client user[MAX_USERS];
    
24. 
    
25. void do_service(gpointer id)
    
26. {
    
27.         gint j;
    
28.         char tobuf[1024];
    
29. 
    
30.         while(read(user[GPOINTER_TO_INT(id)].sd,user[GPOINTER_TO_INT(id)].buf,1024)!= -1)
    
31. {
    
32.         sprintf(tobuf,"%s:%s\n",user[GPOINTER_TO_INT(id)].name,user[GPOINTER_TO_INT(id)].buf);
    
33.         for(j= 0;j<MAX_USERS;j++)
    
34.         {
    
35.                 if(user[j].in_use)
    
36.                 {
    
37.                         write(user[j].sd,tobuf,1024);
    
38.                         g_print("%s",tobuf);
    
39.                 }
    
40.         }
    
41. }
    
42. user[GPOINTER_TO_INT(id)].in_use=FALSE;
    
43. close(user[GPOINTER_TO_INT(id)].sd);
    
44. }
    
45. 
    
46. int main(int argc,char *argv[])
    
47. {
    
48.         gint sd,newsd;
    
49.         struct sockaddr_in *sin;
    
50.         gint slen;
    
51.         gint count= 0;
    
52.         gint flags;
    
53.         gchar buf[1024];
    
54.         gchar tobuf[1024];
    
55.         gint length,i,j;
    
56.        
    
57.         if(!g_thread_supported())
    
58.                 g_thread_init(NULL);
    
59.         else
    
60.                 g_print("thread not supported\n");
    
61.         sd= socket(AF_INET,SOCK_STREAM,0);
    
62.         if(sd== -1)
    
63.         {
    
64.                 g_print("create socket error!\n");
    
65.                 return -1;
    
66.         }
    
67. 
    
68.         sin= g_new(struct sockaddr_in,1);
    
69.         sin->sin_family=AF_INET;
    
70.         sin->sin_port=OURPORT;
    
71.         slen=sizeof(struct sockaddr_in);
    
72.        
    
73.         if(bind(sd,sin,slen)< 0)
    
74.         {
    
75.                 g_print("bind erro!\n");
    
76.                 return -1;
    
77.         }
    
78. 
    
79.         if(listen(sd,8)<0)
    
80.         {
    
81.                 g_print("listen error!\n");
    
82.                 return -1;
    
83.         }
    
84. 
    
85.         for(i=0;i<MAX_USERS;i++)
    
86.                 user[i].in_use=FALSE;
    
87. 
    
88.         flags= fcntl(sd,F_GETFL);
    
89.         fcntl(sd,F_SETFL,flags&~O_NDELAY);
    
90. 
    
91.         for(;;)
    
92.         {
    
93.                 newsd=accept(sd,sin,&slen);
    
94.                 if(newsd== -1)
    
95.                 {
    
96.                         g_print("accept error!\n");
    
97.                         break;
    
98.                 }
    
99.                 else
    
100.                 {
     
101.                         if(count>=MAX_USERS)
     
102.                         {
     
103.                                 sprintf(buf,"用户数量过多服务器不能连接。\n");
     
104.                                 write(newsd,buf,1024);
     
105.                                 close(newsd);
     
106.                         }
     
107.                         else
     
108.                         {
     
109.                                 flags = fcntl(user[i].sd,F_GETFL);
     
110.                                 fcntl(user[i].sd,F_SETFL,O_NONBLOCK);
     
111.                                 user[count].sd=newsd;
     
112.                                 user[count].in_use=TRUE;
     
113.                                 read(newsd,user[count].name,64);
     
114.                                 g_thread_create((GThreadFunc)do_service,(gpointer)count,TRUE,NULL);
     
115.                                 count++;
     
116.                         }
     
117.                 }
     
118.         }
     
119.         close(sd);
     
120.         g_free(sin);
     
121. }
     

复制代码

运行起来总是显示thread not supported。我的编译命令时gcc -o server  server.c `pkg-config --cflags --libs gtk+-2.0 gthread-2.0`

1. #include<gtk/gtk.h>
   
2. #include<string.h>
   
3. #include<sys/types.h>
   
4. #include<sys/socket.h>
   
5. #include<netinet/in.h>
   
6. 
   
7. #define OURPORT 8088
   
8. 
   
9. gint sd;
   
10. struct sockaddr_in s_in;
    
11. gchar username[64];
    
12. gchar buf[1024];
    
13. gchar get_buf[1048];
    
14. gboolean isconnected = FALSE;
    
15. 
    
16. static GtkWidget *text;
    
17. static GtkTextBuffer *buffer;
    
18. static GtkWidget *message_entry;
    
19. static GtkWidget *name_entry;
    
20. static GtkWidget *login_button;
    
21. 
    
22. void get_message(void)
    
23. {
    
24.         GtkTextIter iter;
    
25.         gchar get_buf[1024];
    
26.         gchar buf[1024];
    
27.         while(read(sd,buf,1024)!= -1)
    
28.         {
    
29.                 sprintf(get_buf,"%s",buf);
    
30.                 gdk_threads_enter();
    
31.                 gtk_text_buffer_get_end_iter(buffer,&iter);
    
32.                 gtk_text_buffer_insert(buffer,&iter,get_buf,-1);
    
33.                 gdk_threads_leave();
    
34.         }
    
35. }
    
36. 
    
37. void on_destroy(GtkWidget *widget,GdkEvent *event,gpointer data)
    
38. {
    
39.         sprintf(username,"guest");
    
40.         if(do_connect()== TRUE)
    
41.         {
    
42.                 gtk_widget_set_sensitive(login_button,FALSE);
    
43.                 g_thread_create((GThreadFunc)get_message,NULL,FALSE,NULL);
    
44.         }
    
45.         gtk_widget_destroy(widget);
    
46. }
    
47. 
    
48. void on_button_clicked(GtkButton *button,gpointer data)
    
49. {
    
50.         const gchar *name;
    
51.         name=gtk_entry_get_text(GTK_ENTRY(name_entry));
    
52.         sprintf(username,"%s",name);
    
53.         if(do_connect())
    
54.         {
    
55.                 gtk_widget_set_sensitive(login_button,FALSE);
    
56.                 g_thread_create((GThreadFunc)get_message,NULL,FALSE,NULL);
    
57.         }
    
58.         gtk_widget_destroy(data);
    
59. }
    
60. 
    
61. void create_win(void)
    
62. {
    
63.         GtkWidget *win,*vbox;
    
64.         GtkWidget *button;
    
65. 
    
66.         win=gtk_window_new(GTK_WINDOW_TOPLEVEL);
    
67.         gtk_window_set_title(GTK_WINDOW(win),"输入用户名");
    
68.         gtk_container_set_border_width(GTK_CONTAINER(win),10);
    
69.         g_signal_connect(G_OBJECT(win),"delete_event",G_CALLBACK(on_destroy),NULL);
    
70.         gtk_window_set_modal(GTK_WINDOW(win),TRUE);
    
71.         gtk_window_set_position(GTK_WINDOW(win),GTK_WIN_POS_CENTER);
    
72. 
    
73.         vbox=gtk_vbox_new(FALSE,0);
    
74.         gtk_container_add(GTK_CONTAINER(win),vbox);
    
75.        
    
76.         name_entry=gtk_entry_new();
    
77.         gtk_box_pack_start(GTK_BOX(vbox),name_entry,TRUE,TRUE,5);
    
78.         button=gtk_button_new_from_stock(GTK_STOCK_OK);
    
79.         g_signal_connect(G_OBJECT(button),"clicked",G_CALLBACK(on_button_clicked),win);
    
80.         gtk_box_pack_start(GTK_BOX(vbox),button,FALSE,FALSE,5);
    
81.         gtk_widget_show_all(win);
    
82. 
    
83. }
    
84. 
    
85. gboolean do_connect(void)
    
86. {
    
87.         GtkTextIter iter;
    
88.         gint slen;
    
89.         sd=socket(AF_INET,SOCK_STREAM,0);
    
90.         if(sd<0)
    
91.         {
    
92.                 gtk_text_buffer_get_end_iter(buffer,&iter);
    
93.                 gtk_text_buffer_insert(buffer,&iter,"打开套接字时出错!\n",-1);
    
94.                 return FALSE;
    
95.         }
    
96.         s_in.sin_family=AF_INET;
    
97.         s_in.sin_port=OURPORT;
    
98.         slen=sizeof(s_in);
    
99.         if(connect(sd,&s_in,slen)<0)
    
100.         {
     
101.                 gtk_text_buffer_get_end_iter(buffer,&iter);
     
102.                 gtk_text_buffer_insert(buffer,&iter,"连接服务器时出错!\n",-1);
     
103.                 return FALSE;
     
104.         }
     
105.         else
     
106.         {
     
107.                 gtk_text_buffer_get_end_iter(buffer,&iter);
     
108.                 gtk_text_buffer_insert(buffer,&iter,username,-1);
     
109.                 gtk_text_buffer_get_end_iter(buffer,&iter);
     
110.                 gtk_text_buffer_insert(buffer,&iter,"\n成功与服务器连接。。。\n",-1);
     
111.                 write(sd,username,64);
     
112.                 isconnected=TRUE;
     
113.                 return TRUE;
     
114.         }
     
115. }
     
116. 
     
117. void on_send(GtkButton *button,gpointer data)
     
118. {
     
119.         const char *message;
     
120. 
     
121.         if(isconnected==FALSE) return;
     
122.         message= gtk_entry_get_text(GTK_ENTRY(message_entry));
     
123.         sprintf(buf,"%s\n",message);
     
124.         write(sd,buf,1024);
     
125.         gtk_entry_set_text(GTK_ENTRY(message_entry),"");
     
126. }
     
127. 
     
128. void on_login(GtkWidget *button,gpointer data)
     
129. {
     
130.         create_win;
     
131. }
     
132. 
     
133. void on_delete_event(GtkWidget *widget,GdkEvent *event,gpointer data)
     
134. {
     
135.         close(sd);
     
136.         gtk_main_quit();
     
137. }
     
138. 
     
139. int main(int argc,char *argv[])
     
140. {
     
141.         GtkWidget *window;
     
142.         GtkWidget *vbox,*hbox,*button,*label,*view;
     
143. 
     
144.         if(!g_thread_supported())
     
145.                 g_thread_init(NULL);
     
146.         gtk_init(&argc,&argv);
     
147. 
     
148.         window=gtk_window_new(GTK_WINDOW_TOPLEVEL);
     
149.         gtk_window_set_title(GTK_WINDOW(window),"客户端");
     
150.         g_signal_connect(G_OBJECT(window),"delete_event",G_CALLBACK(on_delete_event),NULL);
     
151.         gtk_container_set_border_width(GTK_CONTAINER(window),10);
     
152. 
     
153.         vbox=gtk_vbox_new(FALSE,0);
     
154.         gtk_container_add(GTK_CONTAINER(window),vbox);
     
155. 
     
156.         hbox=gtk_hbox_new(FALSE,0);
     
157.         gtk_box_pack_start(GTK_BOX(vbox),hbox,FALSE,FALSE,5);
     
158.         label=gtk_label_new("点击登陆按钮连接服务器");
     
159.         gtk_box_pack_start(GTK_BOX(hbox),label,FALSE,FALSE,5);
     
160.         login_button=gtk_button_new_with_label("登录");
     
161.         gtk_box_pack_start(GTK_BOX(hbox),login_button,FALSE,FALSE,5);
     
162.         g_signal_connect(G_OBJECT(login_button),"clicked",G_CALLBACK(on_login),NULL);
     
163. 
     
164.         view=gtk_scrolled_window_new(NULL,NULL);
     
165.         gtk_scrolled_window_set_policy(GTK_SCROLLED_WINDOW(view),GTK_POLICY_AUTOMATIC,GTK_POLICY_AUTOMATIC);
     
166.         text=gtk_text_view_new();
     
167.         gtk_box_pack_start(GTK_BOX(vbox),view,TRUE,TRUE,5);
     
168.         gtk_container_add(GTK_CONTAINER(view),text);
     
169.         buffer=gtk_text_view_get_buffer(GTK_TEXT_VIEW(text));
     
170. 
     
171.         hbox=gtk_hbox_new(FALSE,0);
     
172.         gtk_box_pack_start(GTK_BOX(vbox),hbox,FALSE,FALSE,5);
     
173. 
     
174.         label=gtk_label_new("输入消息：");
     
175.         gtk_box_pack_start(GTK_BOX(hbox),label,FALSE,FALSE,5);
     
176. 
     
177.         message_entry=gtk_entry_new();
     
178.         gtk_box_pack_start(GTK_BOX(hbox),message_entry,FALSE,FALSE,5);
     
179. 
     
180.         button=gtk_button_new_with_label("发送");
     
181.         gtk_box_pack_start(GTK_BOX(hbox),button,FALSE,FALSE,5);
     
182.         g_signal_connect(G_OBJECT(button),"clicked",G_CALLBACK(on_send),NULL);
     
183. 
     
184.         gtk_widget_show_all(window);
     
185. 
     
186.         gdk_threads_enter();
     
187.         gtk_main();
     
188.         gdk_threads_leave();
     
189. 
     
190.         return FALSE;
     
191. }

复制代码

这个是与之对应的客户端程序，大家帮忙看下，谢谢，一个课程设计要急用，跪谢各位

mybooks_zzz

运行时总是显示thread not supported，我是初学linux网络编程，不知道那里除了问题，请教下各位，小弟感激不尽

mybooks_zzz

我的系统是fedota19

uniken

       -pthread
           Adds support for multithreading with the pthreads library.  This
           option sets flags for both the preprocessor and linker.

试试看是不是在编译的时候，加上 -pthread