使用LibSoup写简单的HTTP服务器

ACTom

WebkitGtk在Windows下的完成度远远没有达到Linux的水平。
在Windows下做测试的时候发现了一个很大的问题，WebkitGtk在Windows下居然不能载入磁盘上的文件。
考虑到它可以载入http协议的文件，而WebkitGtk依赖libsoup，研究了下Libsoup的tests，写了一个简单的http服务器。

1. #include <libsoup/soup.h>
3. static void
4. do_get (SoupServer *server, SoupMessage *msg, const char *path)
5. {
6. char *slash;
7. struct stat st;
8. int fd;
9. static char *path2 = NULL;
11. if (!path2){g_free(path2); path2=NULL;}
12. path2 = g_build_filename((const gchar *)global_get("htmlhome"), path, NULL);
14. if (stat (path2, &st) == -1) {
15. if (errno == EPERM)
16. soup_message_set_status (msg, SOUP_STATUS_FORBIDDEN);
17. else if (errno == ENOENT)
18. soup_message_set_status (msg, SOUP_STATUS_NOT_FOUND);
19. else
20. soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
21. return;
22. }
24. if (S_ISDIR (st.st_mode)) {
25. char *index_path;
27. slash = strrchr (path, '/');
28. if (!slash || slash[1]) {
29. char *uri, *redir_uri;
31. uri = soup_uri_to_string (soup_message_get_uri (msg), FALSE);
32. redir_uri = g_strdup_printf ("%s/", uri);
33. soup_message_headers_append (msg->response_headers,
34. "Location", redir_uri);
35. soup_message_set_status (msg, SOUP_STATUS_MOVED_PERMANENTLY);
36. g_free (redir_uri);
37. g_free (uri);
38. return;
39. }
41. index_path = g_strdup_printf ("%s/index.html", path);
42. if (stat (index_path, &st) != -1) {
43. do_get (server, msg, index_path);
44. g_free (index_path);
45. return;
46. }
48. char *buf = "<title>Forbidden</title><h1>Forbidden</h1>", len[10];
49. sprintf(len, "%d", strlen(buf));
51. soup_message_body_append (msg->response_body, SOUP_MEMORY_TAKE,
52. buf, strlen(buf));
53. soup_message_headers_append (msg->response_headers,
54. "Content-Length", len);
55. soup_message_set_status(msg, SOUP_STATUS_FORBIDDEN);
56. return;
57. }
59. fd = open (path2, O_RDONLY);
60. if (fd == -1) {
61. soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
62. return;
63. }
65. if (msg->method == SOUP_METHOD_GET) {
66. char *buf;
68. buf = g_malloc (st.st_size);
69. read (fd, buf, st.st_size);
70. close (fd);
71. soup_message_body_append (msg->response_body, SOUP_MEMORY_TAKE,
72. buf, st.st_size);
73. } else /* msg->method == SOUP_METHOD_HEAD */ {
74. char *length;
76. /* We could just use the same code for both GET and
77. * HEAD. But we'll optimize and avoid the extra
78. * malloc.
79. */
80. length = g_strdup_printf ("%lu", (gulong)st.st_size);
81. soup_message_headers_append (msg->response_headers,
82. "Content-Length", length);
83. g_free (length);
84. }
86. soup_message_set_status (msg, SOUP_STATUS_OK);
87. }
89. static void
90. do_put (SoupServer *server, SoupMessage *msg, const char *path)
91. {
92. struct stat st;
93. FILE *f;
94. gboolean created = TRUE;
95. static char *path2 = NULL;
97. if (!path2){g_free(path2); path2=NULL;}
99. path2 = g_build_filename((const gchar *)global_get("htmlhome"), path, NULL);
101. if (stat (path2, &st) != -1) {
102. const char *match = soup_message_headers_get_one (msg->request_headers, "If-None-Match");
103. if (match && !strcmp (match, "*")) {
104. soup_message_set_status (msg, SOUP_STATUS_CONFLICT);
105. return;
106. }
108. if (!S_ISREG (st.st_mode)) {
109. soup_message_set_status (msg, SOUP_STATUS_FORBIDDEN);
110. return;
111. }
113. created = FALSE;
114. }
116. f = fopen (path2, "w");
117. if (!f) {
118. soup_message_set_status (msg, SOUP_STATUS_INTERNAL_SERVER_ERROR);
119. return;
120. }
122. fwrite (msg->request_body->data, 1, msg->request_body->length, f);
123. fclose (f);
125. soup_message_set_status (msg, created ? SOUP_STATUS_CREATED : SOUP_STATUS_OK);
126. }
128. static void
129. server_callback (SoupServer *server, SoupMessage *msg,
130. const char *path, GHashTable *query,
131. SoupClientContext *context, gpointer data)
132. {
133. SoupMessageHeadersIter iter;
135. soup_message_headers_iter_init (&iter, msg->request_headers);
137. if (msg->method == SOUP_METHOD_GET || msg->method == SOUP_METHOD_HEAD)
138. do_get (server, msg, path);
139. else if (msg->method == SOUP_METHOD_PUT)
140. do_put (server, msg, path);
141. else
142. soup_message_set_status (msg, SOUP_STATUS_NOT_IMPLEMENTED);
143. }
145. int init_server()
146. {
147. SoupServer *server;
148. int port = SOUP_ADDRESS_ANY_PORT;
150. server = soup_server_new (SOUP_SERVER_PORT, port,
151. SOUP_SERVER_SERVER_HEADER, "AwayFramework ",
152. NULL);
153. if (!server) {
154. g_log("AFR", G_LOG_LEVEL_ERROR, "Unable to bind to server port %d\n", port);
155. return -1;
156. }
158. soup_server_add_handler (server, NULL,
159. server_callback, NULL, NULL);
160. g_log("AFR", G_LOG_LEVEL_INFO, "Starting Server on port %d",
161. soup_server_get_port (server));
162. soup_server_run_async (server);
164. return soup_server_get_port (server);
165. }

复制代码

转自：http://www.awaysoft.com/taor/%e6 ... 8a%a1%e5%99%a8.html

ekd123

看上去還是有點複雜{:soso_e122:}

ACTom

ekd123 发表于 2013-1-12 18:37
看上去還是有點複雜

不到200行还好吧。。。。。仔细看看其实挺简单的