C Socket小样例

         发个C Socket的小样例了。来映衬下《Java Socket基础》^^。很久前的东西了，都忘的差不多了==。

1. #include "stdafx.h" 
2.  
3. // 字符缓冲 
4. static char buf[BUFSIZ]; 
5.  
6. // 截取字符串首个''内内容 
7. char * truncate(char *s) { 
8.     int flag = 0; 
9.     char *p, *q; 
10.     p = buf; 
11.     // 不是字符串末尾 
12.     while (*s != '\0') { 
13.         // 如果未遇到了字符' 
14.         if (flag == 0) { 
15.             // 如果字符为'时 
16.             if (*s == '\'') { 
17.                 //printf("首次遇到符号==%c==\n", *s); 
18.                 flag = 1; 
19.             } else { 
20.                 s++; 
21.             } 
22.         } 
23.         // 如果遇到了首个字符 
24.         if (flag == 1) { 
25.             // 如果下个符号为'或到底时 
26.             s++; 
27.             if (*s == '\'' || *s == '\0' ) { 
28.                 //printf("再次遇到符号==%c==\n", *s); 
29.                 // 字符串结尾标记 
30.                 *p = '\0'; 
31.                 break; 
32.             } else { 
33.                 //printf("==%c==\n", *s); 
34.                 *(p++) = *s; 
35.             } 
36.         } 
37.     } 
38.     q =(char *)malloc(strlen(buf)); 
39.     return strcpy(q, buf); 
40. } 
41.  
42. // 从s1中截取以s2开始的后的''内容 
43. char * getContent(char *s1, char *s2) { 
44.     int flag = 0; 
45.     char *p, *q, *s; 
46.     p = s1; 
47.     while (*p != '\0') { 
48.         // 等于s2首字符时 
49.         if (*p == *s2) { 
50.             flag = 1; 
51.             s = p; 
52.             q = s2; 
53.             // 判断接下去的字符是否相等 
54.             while (*q != '\0') { 
55.                 // s1读至了末尾 
56.                 if (*s == '\0') { 
57.                     flag = 0; 
58.                     break; 
59.                 } else { 
60.                     if (*q++ != *s) { 
61.                         flag = 0; 
62.                         break; 
63.                     } 
64.                 } 
65.                 s++; 
66.             } 
67.         } 
68.         // 出现包含字符后 
69.         if (flag == 1) { 
70.             //printf("==%c==\n", *(p + 1)); 
71.             return truncate(s); 
72.         } 
73.         p++; 
74.     } 
75.     return NULL; 
76. } 
77.  
78. char * analyzeUrl(char *url) 
79. { 
80.     WSADATA WSAData={0}; 
81.     SOCKET sockfd; 
82.     struct sockaddr_in addr; 
83.     struct hostent *pURL; 
84.     char myurl[BUFSIZ]; 
85.     char *pHost = 0, *pGET = 0; 
86.     char host[BUFSIZ], GET[BUFSIZ]; 
87.     char header[BUFSIZ] = ""; 
88.     // 扩大点，一次性读进去 
89.     static char text[BUFSIZ]; 
90.  
91.     // 解析后信息 
92.     int hasFlvTitle = 0, hasFplayer = 0; 
93.     char *flvTitle, *fPlayer, *result; 
94.  
95.     /* 
96.     * windows下使用socket必须用WSAStartup初始化，否则不能调用 
97.     */ 
98.     if(WSAStartup(MAKEWORD(2,2), &WSAData)) 
99.     { 
100.         printf("WSA failed!\n"); 
101.         return NULL; 
102.     } 
103.  
104.     /* 
105.     * 分离url中的主机地址和相对路径 
106.     */ 
107.     strcpy(myurl, url); 
108.     for (pHost = myurl; *pHost != '/' && *pHost != '\0'; ++pHost); 
109.     if ( (int)(pHost - myurl) == strlen(myurl) ) 
110.         strcpy(GET, "/"); 
111.     else 
112.         strcpy(GET, pHost); 
113.     *pHost = '\0'; 
114.     strcpy(host, myurl); 
115.     printf("网页地址：http://%s%s\n\n", host, GET); 
116.  
117.     /* 
118.     * 设定socket参数,并未真正初始化 
119.     */ 
120.     sockfd = socket(PF_INET, SOCK_STREAM, IPPROTO_TCP); 
121.     pURL = gethostbyname(host); 
122.     addr.sin_family = AF_INET; 
123.     addr.sin_addr.s_addr = *((unsigned long*)pURL->h_addr); 
124.     addr.sin_port = htons(80); 
125.  
126.     /* 
127.     * 组织发送到web服务器的信息 
128.     * 为何要发送下面的信息请参考HTTP协议的约定 
129.     */ 
130.     strcat(header, "GET "); 
131.     strcat(header, GET); 
132.     strcat(header, " HTTP/1.1\r\n"); 
133.     strcat(header, "HOST: "); 
134.     strcat(header, host); 
135.     strcat(header, "\r\nConnection: Close\r\n\r\n"); 
136.  
137.     /* 
138.     * 连接到服务器，发送请求header，并接受反馈（即网页源代码） 
139.     */ 
140.     printf("正在获取网页代码...\n\n"); 
141.     connect(sockfd,(SOCKADDR *)&addr,sizeof(addr)); 
142.  
143.     send(sockfd, header, strlen(header), 0); 
144.      
145.     printf("开始分析网页代码...\n\n"); 
146.     while (1) 
147.     { 
148.         if (recv(sockfd, text, BUFSIZ, 0) > 0) { 
149.             //printf("\n\n==========\n\n"); 
150.             //printf("%s", text); 
151.  
152.             if (0 == hasFlvTitle) { 
153.                 flvTitle = getContent(text, "flvTitle:"); 
154.                 // 如果读到了flvTitle 
155.                 if (flvTitle != NULL) { 
156.                     if (strlen(flvTitle) > 0) { 
157.                         hasFlvTitle = 1; 
158.                         printf("读到了flvTitle：%s\n\n", flvTitle); 
159.                     } else { 
160.                         //printf("未读到了flvTitle\n\n"); 
161.                         break; 
162.                     } 
163.                 } 
164.             } 
165.  
166.             if (0 == hasFplayer) { 
167.                 fPlayer = getContent(text, "Fplayer:"); 
168.                 // 如果读到了Fplayer 
169.                 if (fPlayer != NULL) { 
170.                     if(strlen(fPlayer) > 0) { 
171.                         hasFplayer = 1; 
172.                         printf("读到了Fplayer：%s\n\n", fPlayer); 
173.                         break; 
174.                     } else { 
175.                         //printf("未读到了Fplayer\n\n"); 
176.                         break; 
177.                     } 
178.                 } 
179.             } 
180.  
181.             strnset(text, '\0', BUFSIZ); 
182.         } else { 
183.             break; 
184.         } 
185.     } 
186.      
187.     closesocket(sockfd); 
188.     WSACleanup(); 
189.  
190.     if (1 == hasFlvTitle && 1 == hasFplayer) { 
191.         //printf("==flvTitle：%s==\n\n", flvTitle); 
192.         //printf("==Fplayer：%s==\n\n", fPlayer); 
193.         *buf = '\0'; 
194.         strcat(buf, "http://v.6.cn"); 
195.         strcat(buf, fPlayer); 
196.         strcat(buf, "?fileName="); 
197.         strcat(buf, flvTitle); 
198.         strcat(buf, "&autoplay=true"); 
199.  
200.         result =(char *)malloc(strlen(buf)); 
201.  
202.         return strcpy(result, buf); 
203.     } 
204.  
205.     return NULL; 
206.  
207. } 
208.  
209. int main(int argc, char * argv[]) 
210. //int _tmain(int argc, _TCHAR* argv[]) 
211. { 
212.     *buf = '\0'; 
213.     char *url, *newUrl; 
214.     if (argc > 1) { 
215.         strcat(buf, "v.6.cn/"); 
216.         strcat(buf, *(argv+1)); 
217.         url =(char *)malloc(strlen(buf)); 
218.         strcpy(url, buf); 
219.         //printf("==%s==\n\n", *(argv+1)); 
220.     } else { 
221.         url = "v.6.cn/541218"; 
222.     } 
223.  
224.     printf("开始...\n\n"); 
225.  
226.     newUrl = analyzeUrl(url); 
227.     if (newUrl == NULL) { 
228.         printf("未解析到地址/(ㄒoㄒ)/~~\n\n"); 
229.     } else { 
230.         printf("解析地址：%s\n\n",newUrl); 
231.         *buf = '\0'; 
232.         strcat(buf, "rundll32 url.dll,FileProtocolHandler \""); 
233.         strcat(buf, newUrl); 
234.         strcat(buf, "\""); 
235.         system(buf); 
236.     } 
237.  
238.     printf("结束！\n\n"); 
239.  
240.     system("PAUSE"); 
241.     return 0; 
242. } 

1. public class VideoUtil { 
2.  
3.     // 连接超时15秒 
4.     public static final int TIMEOUT = 15; 
5.  
6.     // 读取源代码时判断获得js代码page对象中的flvTitle（直播文件名）和Fplayer(播放地址)，并且由其组成真实地址 
7.     public static String getVideoRealUrl(String urlStr, InfoFrame frame) { 
8.         String flvTitle = "", fPlayer = ""; 
9.         try { 
10.             frame.addInfo("网页地址：" + urlStr); 
11.             frame.addInfo("正在获取网页代码..."); 
12.             InputStream is = getNetInputStream(urlStr, frame); // 获取网页输入流 
13.             if (null == is) { 
14.                 frame.addInfo("解析超时或者地址有误O__O\"…"); 
15.                 return null; 
16.             } 
17.  
18.             frame.addInfo("开始分析网页代码..."); 
19.             InputStreamReader isr = new InputStreamReader(is); 
20.             BufferedReader br = new BufferedReader(isr); 
21.             String s = null; 
22.             boolean hasReadFlvTitle = false, hasReadFplayer = false; 
23.             while (true) { 
24.                 s = br.readLine(); 
25.                 if (null == s) { 
26.                     is.close(); 
27.                     frame.addInfo("该直播房间异常，请重新选择！"); 
28.                     return null; 
29.                 } 
30.  
31.                 // 如果读到了flvTitle 
32.                 if (!hasReadFlvTitle && s.indexOf("flvTitle:") != -1) { 
33.                     hasReadFlvTitle = true; 
34.                     flvTitle = getContent(s); 
35.                     // 没有内容时返回null 
36.                     if (null == flvTitle) { 
37.                         frame.addInfo("直播文件名信息为空，还未开始直播！"); 
38.                         is.close(); 
39.                         return null; 
40.                     } else { 
41.                         frame.addInfo("获取了直播文件名信息：" + flvTitle); 
42.                     } 
43.                 } 
44.  
45.                 // 如果读到了flvTitle 
46.                 if (!hasReadFplayer && s.indexOf("Fplayer:") != -1) { 
47.                     hasReadFplayer = true; 
48.                     fPlayer = getContent(s); 
49.                     // 没有内容时返回null 
50.                     if (null == fPlayer) { 
51.                         frame.addInfo("flash播放信息为空！"); 
52.                         is.close(); 
53.                         return null; 
54.                     } else { 
55.                         frame.addInfo("获取了flash播放信息：" + fPlayer); 
56.                         break; // 跳出循环 
57.                     } 
58.                 } 
59.  
60.             } 
61.             is.close(); 
62.         } catch (IOException e) { 
63.             frame.addInfo("发生异常！"); 
64.             e.printStackTrace(); 
65.             return null; 
66.         } 
67.         return "http://v.6.cn" + fPlayer + "?fileName=" + flvTitle 
68.                 + "&autoplay=true"; 
69.     } 
70.  
71.     // 获取一个字符串''中的内容 
72.     private static String getContent(String str) { 
73.         int beginIndex = str.indexOf("'"); 
74.         int endIndex = str.lastIndexOf("'"); 
75.         if (beginIndex + 1 == endIndex) { 
76.             return null; 
77.         } 
78.         return str.substring(beginIndex + 1, endIndex); 
79.     } 
80.  
81.     // 获取网页输入流 
82.     public static InputStream getNetInputStream(String urlStr, InfoFrame frame) { 
83.         try { 
84.             URL url = new URL(urlStr); 
85.             URLConnection conn = url.openConnection(); 
86.             conn.setRequestProperty( 
87.                     "User-Agent", 
88.                     "Mozilla/5.0 (Windows; U; Windows NT 5.1; zh-CN; rv:1.9.0.15) Gecko/2009101601 Firefox/3.0.15 (.NET CLR 3.5.30729)"); 
89.             conn.setConnectTimeout(TIMEOUT * 1000); 
90.             conn.connect(); 
91.             InputStream is = conn.getInputStream(); 
92.             return is; 
93.         } catch (Exception e) { 
94.         } 
95.         return null; 
96.     } 
97.  
98. } 

1. // 打开浏览器访问url 
2. public static void openURL(String url) { 
3.     String osName = System.getProperty("os.name"); 
4.     try { 
5.         if (osName.startsWith("Mac OS")) { 
6.             // Mac 
7.             Class fileMgr = Class.forName("com.apple.eio.FileManager"); 
8.             Method openURL = fileMgr.getDeclaredMethod("openURL", 
9.                     new Class[] { String.class }); 
10.             openURL.invoke(null, new Object[] { url }); 
11.         } else if (osName.startsWith("Windows")) { 
12.             // Windows 
13.             Runtime.getRuntime().exec( 
14.                     "rundll32 url.dll,FileProtocolHandler " + url); 
15.         } else { 
16.             // assume Unix or Linux 
17.             String[] browsers = { "firefox", "opera", "konqueror", 
18.                     "epiphany", "mozilla", "netscape" }; 
19.             String browser = null; 
20.             for (int count = 0; count < browsers.length && browser == null; count++) { 
21.                 if (Runtime.getRuntime() 
22.                         .exec(new String[] { "which", browsers[count] }) 
23.                         .waitFor() == 0) { 
24.                     browser = browsers[count]; 
25.                 } 
26.             } 
27.             if (browser != null) { 
28.                 Runtime.getRuntime().exec(new String[] { browser, url }); 
29.             } 
30.         } 
31.     } catch (Exception e) { 
32.         e.printStackTrace(); 
33.     } 
34. } 

         ps：附件放个打包成的jar，运行试试呗。工程下载至Click here！