初探Linux网络编程：在线英语词典的实现

---

闲话少说

此文章为在线英语词典实现,第一次基本独立做项目，大部门功能没题目，不敷的是代码冗余有点多，还可能有些小BUG。
仅做记载并且分享本身学习Linux网络编程的过程，学艺不精，code新人，如有错误接待在评论区讨论、指正！，若文章内容对你有帮助，希望可以给我点个赞！

---

1. 思路构筑（想框架，理流程）

做完本次项目，进一步体会到思路构筑的重要性；若你向我一样经验不敷，最好不要脑子一热就狂写一堆，到了项目做到一半发现要大改……说多都是泪。这部门多花时间一点也无妨。
先来看一下做该项目的大致思路：写好大致框架后，一个模块一个模块的添，模块边写边测试。“让服务器做所有事变” 这种想法是大忌。 有些事变让客户端去做会大大降低你项目编码的难度。二者如何分工，请看下文。
1.1 大致思路

1.1.1 功能模块

• 用户界面：告诉用户可以做些什么事变
  
• 账号操作：登录或注册
  
• 查询操作：查询单词或者成功查询的历史
  

1.1.2 服务器

• 一个数据库，数据库内三张表user, word, history ，分别存放用户，单词，和成功查询单词历史信息
  
• 接收请求
  
  
  
  • 1.注册：得到用户 id pwd 并添加到 user 表中
    
  • 2.登录：得到用户 id pwd 到 user 表中比对 id 和 pwd
    
  • 3.查单词：得到用户输入单词，到 word 表中查找
    
  • 4.查历史：根据用户 id，到 history 中查找记载
    
  
  
• 返回相应结果
  

1.1.3 客户端

• 用户界面：提示用户当前可以做什么事变
  
• 得到用户请求，并发送给服务器
  
• 接收回复结果，做相应处理
  

1.1.4 交互流程

该项目简单来说就是：用户只有在登录成功之后才可以进入查询环节；进入查询环节之后可以不停查询，直到用户在“查单词“环节输入 ”Q“ 之后才会回退到账号界面。
固然这并不灵活，是后续可以改进的点。
   

  服务器启动的条件下，用户运行客户端，输入数字(1, 2, 3, 4)即可做对应的事变。
数字对应功能如下图所示
   账号界面

  查询界面

  

---

2. 代码

2.1 部门效果展示

   登录成功

单词查询结果

历史查询结果，打印有点小题目

  2.2 项目概况 readMe.txt

服务器端

• 主函数 server.c
  
• 功能函数 tool.c
  
• 编译下令: gcc server.c tool.c -lsqlite3 -o server
  
• 运行下令: ./server IP port
  
• 初次运行下令： ./server IP port num --> num 任意数字即可
  
• 词典数据文件：dict.txt
  

客户端

• 主函数 client.c
  
• 功能函数 tool.c
  
• 编译下令: gcc clien.c tool.c -lsqlite3 -o client
  
• 运行下令: ./client IP port
  

2.3.头文件 tool.h

包罗了客户端和服务器需要用到的所有功能模块函数接口（并不是很好，最好客户端和服务器模块功能函数分开放）

1. #ifndef _TOOL_H_
2. #define _TOOL_H_
4. #include <stdio.h>
6. #include <sys/types.h>
7. #include <sys/socket.h>
8. #include <arpa/inet.h>
10. #include <signal.h>
11. #include <wait.h>
13. #include <time.h>
14. #include <sqlite3.h>
15. #include <stdlib.h>
16. #include <string.h>
17. #include <unistd.h>
19. #define R 1 // register
20. #define L 2        // login
21. #define C 3 // check
22. #define H 4        // history
23. #define Q 5 // quit
24. #define GET_ID_ERR 6        //获取id 失败
25. #define GET_PWD_ERR 7        //获取pwd 失败
26. #define ID_ERR 8        // 用户id 错误
27. #define PWD_ERR 9        // 用户pwd 错误
30. //用户界面
31. void UI_account(void);
32. //查询界面
33. void UI_check(void);
34. // 初始化数据库,只是准备，后续使用仍需要手动打开
35. int database_init(char *dbname);
36. // 注册
37. int user_add(int connfd, sqlite3 *db);
38. // 登陆
39. int user_login(int connfd, sqlite3 *db);
40. // 查单词
41. int check(int connfd, sqlite3 *db, int id);
42. // 成功历史查询
43. int history(int connfd, sqlite3 *db, int id);
44. // 定义用户帐号函数,登陆成功返回用户id
45. int account(int connfd, sqlite3 *db,int mode);
46. // 行为函数
47. int operation(int connfd, sqlite3 *db, int mode, int id);
48. // 服务器初始化
49. int server_init(char *ip, char* port);
51. #endif

复制代码

2.4 功能函数 tool.c

1. #include "tool.h"
3. //帐号界面
4. void UI_account(void){
5.         char buf[512] = {0};
6.         strcat(buf,"******************************************\n");
7.         strcat(buf,"*                                        *\n");
8.         strcat(buf,"*     **     输入数字即可开始    **      *\n");
9.         strcat(buf,"*                                        *\n");
10.         strcat(buf,"*            1:注册   2:登陆             *\n");
11.         strcat(buf,"*                                        *\n");
12.         strcat(buf,"******************************************\n");
13.         printf("%s", buf);
14. }
16. // 查询界面
17. void UI_check(void){
18.         char buf[512] = {0};
19.         strcat(buf,"******************************************\n");
20.         strcat(buf,"*                                        *\n");
21.         strcat(buf,"*     **    输入数字即可开始    **       *\n");
22.         strcat(buf,"*                                        *\n");
23.         strcat(buf,"*        3:查单词      4:历史查询        *\n");
24.         strcat(buf,"*                                        *\n");
25.         strcat(buf,"******************************************\n");
26.         printf("%s", buf);
27. }
29. // 初始化数据库,只是准备，后续使用仍需要手动打开
30. int database_init(char *dbname)
31. {
32.         puts("---             服务器初始化中，请稍候...           ---");
33.         char sql[256] = {0};
34.         sqlite3 *db;
35.         if(-1 == sqlite3_open(dbname, &db)){
36.                 printf("%s open error: %s\n", dbname, sqlite3_errmsg(db));
37.                 return -1;
38.         }
40.         /*------------------------------------------------------------------------*/
41.         // 初始化 user(id int primary key, password int)
42.         strcpy(sql, "create table if not exists user(id int primary key,\
43.                 password int)");
44.         if(0 != sqlite3_exec(db, sql, NULL, NULL, NULL)){
45.                 printf("user create error: %s\n", sqlite3_errmsg(db));
46.                 return -1L;
47.         }
49.         /*------------------------------------------------------------------------*/
50.         // 创建 word 数据库
51.         strcpy(sql, "create table if not exists word(word str(15),\
52.                 meaning text)");
53.         if(0 != sqlite3_exec(db, sql, NULL, NULL, NULL)){
54.                 printf("word create error: %s\n", sqlite3_errmsg(db));
55.                 return -1;
56.         }
57.         //词典文件上传到数据库
58.         FILE *fp = fopen("dict.txt", "r+");
59.         if(NULL == fp){
60.                 perror("dict fopen");
61.                 return -1;
62.         }
63.         char buf[64] = {0};//词条
64.         char word[32] = {0}; //单词
65.         while(fgets(buf, sizeof(buf), fp)){
66.                 //把单词从词条中提取出来
67.                 char *cut = strstr(buf, " ");
68.                 strncpy(word, buf, cut-buf);
69.                 //单词和词条添加到数据库word中
70.                 char sql[128] = {0};
71.                 sprintf(sql, "insert into word values('%s', '%s')",word, buf);
72.                 if(0 != sqlite3_exec(db, sql, NULL, NULL, NULL)){
73.                         printf("word insert: %s\n", sqlite3_errmsg(db));
74.                         return -1;
75.                 }
76.                 memset(buf, 0, sizeof(buf));
77.                 memset(word, 0, sizeof(word));
78.         }
80.         /*------------------------------------------------------------------------*/
81.         // 初始化 history(id int primary key, word str(40), time text)
82.         strcpy(sql, "create table if not exists history(id int,\
83.                 word str(40), time text)");
84.         if(0 != sqlite3_exec(db, sql, NULL, NULL, NULL)){
85.                 printf("history create error: %s\n", sqlite3_errmsg(db));
86.                 return -1;
87.         }
88.         sqlite3_close(db);
89.         return 0;
90. }
92. /*------------------------------------------------------------------------*/
93. // 注册
94. int user_add(int connfd, sqlite3 *db){
95.         // id是主键，sqlite3会判断 id 唯一性，所以这里不用
96.         int id, pwd;
97.         char sql[128] = {0};
98.         char buf[128] = {0};
99.         // 接受数据，拼接sql语句
100.         recv(connfd, (void*)&id, sizeof(id), 0);
101.         recv(connfd, (void*)&pwd, sizeof(pwd), 0);
102.        
103.         if(9 >= id)
104.                 return ID_ERR;// id 不合法
106.         sprintf(sql, "insert into user values(%d,%d);", id, pwd);
107.         if(0 != sqlite3_exec(db, sql, NULL, NULL, NULL)){
108.                 printf("add user error: %s\n", sqlite3_errmsg(db));
109.                 return ID_ERR;
110.         }
111.         // 注册成功
112.         printf("用户id：%d  pwd：%d 注册成功!\n",id, pwd);
113.         return 0;
114. }
116. /*------------------------------------------------------------------------*/
117. // 登陆, 登陆成功返回用户id
118. int user_login(int connfd, sqlite3 *db){
119.         int id, pwd;
120.         char **result;
121.         int row, col;
122.         char buf[128] = {0};
123.         char sql[128] = {0};
125.         // 获取登陆用户输入的id pwd
126.         int ret = recv(connfd, &id, sizeof(id), 0);
127.         if(-1 == ret){
128.                 perror("获取登陆用户id 失败");
129.                 return GET_ID_ERR;
130.         }else if(0 == ret){
131.                 printf("客户端退出\n");
132.         }
133.         ret = recv(connfd, &pwd, sizeof(pwd), 0);
134.         if(-1 == ret){
135.                 perror("获取登陆用户pwd 失败");
136.                 return GET_PWD_ERR;
137.         }else if(0 == ret){
138.                 printf("客户端退出\n");
139.         }
140.         //判断登陆id合法性
141.         if(9 >= id){
142.                 return ID_ERR;//不合法
143.         }
145.         printf("已登陆用户-----id: %d, pwd: %d\n", id, pwd);
147.         // 查看 user 表中是否有该用户       
148.         sprintf(sql, "select * from user where id = %d", id);
149.         if(0 != sqlite3_get_table(db, sql, &result, &row, &col, NULL)){
150.                 printf("login user error: %s\n", sqlite3_errmsg(db));
151.                 return ID_ERR;//用户不存在
152.         }
154.         for(int i=1; i<=row; i++){
155.                 for(int j=0; j<col;j++){
156.                         //判断用户id
157.                         if(id == atoi(result[i * col + j])){
158.                                 //判断用户密码
159.                                 if(pwd == atoi(result[i*col+j+1])){
160.                                         return id;
161.                                 }else{
162.                                         return PWD_ERR;
163.                                 }
164.                         }
165.                 }
166.         }
167.         return -1;
168. }
170. /*------------------------------------------------------------------------*/
171. // 可查一次查单词, 且上传成功查询历史
172. // 返回值：正常查询发送信息给客户端，返回 0 ;出错 -1
173. int check(int connfd, sqlite3 *db, int id){
174.         char **result;
175.         int row, col;
176.         char sql[128] = {0};
177.         char buf[128] = {0};
178.         // 提取 word 表的数据
179.         strcpy(sql, "select * from word");
180.         if(0 != sqlite3_get_table(db, sql, &result, &row, &col, NULL)){
181.                 return -1;
182.         }
183.         //获得用户单词信息
184.         char input[32] = {0};
185.         recv(connfd, input, sizeof(input), 0);
186.         int input_len = strlen(input);
187.         printf("客户端获得单词：%s\n", input);
188.         // 得到Q退出
189.         if(0 == strncmp(input, "Q", 1)){
190.                 return Q; //
191.         }
192.         //判断word
193.         int index = col;//查询所用下标,因为 col 等于字段数
194.         int flag = 0;//标记单词查询状态 0：未找到  1：找到
195.         int max = row*col-2; //单词以及解释的总个数， 2 是字段数 word, meaning
196.         for(int i=0; i<=row; i++){
197.                 if(1 == flag)//找到直接退出循环
198.                         break;
199.                 for(int j=0; j<col;j++){
200.                         //接收数据库数据（否则无法获取单词真正长度）
201.                         char word[20] = {0};
202.                         strcpy(word, result[index]);
203.                         int word_len = strlen(word);
204.                         //判断单词内容与单词长度
205.                         if(input_len == word_len && 0 == strncmp(input, result[index], strlen(input))){
206.                                 // 成功查到发送解释 result[index+1]
207.                                 sprintf(buf, "%s", result[index+1]);
208.                                 send(connfd, buf, strlen(buf), 0);
209.                                 memset(buf, 0, sizeof(buf));
211.                                 /* -------------------上传历史记录--------------*/
212.                                 // 获取查询时间
213.                                 time_t tm;
214.                                 time(&tm);
215.                                 struct tm *tp = localtime(&tm);
216.                                 char timmsg[32] = {0};
217.                                 sprintf(timmsg,"%d/%d/%d %d:%d:%d\n", tp->tm_year+1900,
218.                                                 tp->tm_mon+1, tp->tm_mday, tp->tm_hour,
219.                                                 tp->tm_min, tp->tm_sec);
221.                                 char sql[128] = {0};
222.                                 sprintf(sql,"insert into history values(%d,'%s','%s')",id,word,timmsg);
223.                                 if(-1 == sqlite3_exec(db, sql, NULL, NULL, NULL)){
224.                                         return -1;
225.                                 }               
226.                                 flag = 1;
227.                                 break;
228.                         }
229.                         index+=2;
230.                         index %= max;//防止段错误
231.                 }
232.         }
233.         //循环退出时 flag 仍为 0 则未找到
234.         if(0 == flag){
235.                 strcpy(buf, "单词未找到\n");
236.                 send(connfd, buf, strlen(buf), 0);
237.                 return 0;
238.         }
239.         return 0;
240. }
242. /*------------------------------------------------------------------------*/
243. // 成功查询的历史
244. int history(int connfd, sqlite3 *db, int id){
245.         char sql[128] = {0};
246.         char buf[128] = {0};
247.         char **result;
248.         int row, col;
249.         sprintf(sql, "select * from history where id=%d", id);
250.         if(-1 == sqlite3_get_table(db, sql, &result, &row, &col, NULL)){
251.                 sprintf(buf,"select history: %s\n", sqlite3_errmsg(db));
252.                 send(connfd, buf, strlen(buf), 0);
253.                 memset(buf, 0, sizeof(buf));
254.                 return -1;
255.         }
257.         int max = col * row + 3;// 3 是字段数
258.         if(3 == max){// max 为3 该用户无成功查询记录
259.                 strcpy(buf, "NONE!");
260.                 send(connfd, buf, strlen(buf), 0);
261.                 return -1;
262.         }else{
263.                 strcpy(buf,"\n---------------成功查询历史----------------\n");
264.                 send(connfd, buf, strlen(buf), 0);
265.                 memset(buf, 0, sizeof(buf));
266.                 for(int i=0; i<=row; i++){
267.                         for(int j=0; j<col; j++){        // j 从3 开始，不传字段名
268.                                 sprintf(buf, "%s ", result[i*col+j]);
269.                                 send(connfd, buf, strlen(buf), 0);
270.                                 usleep(1000);
271.                                 memset(buf, 0, sizeof(buf));
272.                         }
273.                 }
274.                 // 历史数据发送完成,发送结束信息
275.                 strcpy(buf, "DONE!");
276.                 send(connfd, buf, strlen(buf), 0);
277.         }
278.         return 0;
279. }
281. /*------------------------------------------------------------------------*/
282. // 帐号操作,函数注册成功返回 0，登陆成功返回id
283. int account(int connfd, sqlite3 *db, int mode){
284.         int id;
285.         char buf[128] = {0};
286.         //注册
287.         if(R == mode){
288.                 int ret = user_add(connfd, db);
289.                 if(0 == ret){
290.                         printf("新用户注册成功！\n");
291.                 }else if(ID_ERR){
292.                         return ID_ERR;
293.                 }
294.                 return 0;//注册成功
295.         }else if(L ==mode){
296.                 // 登陆
297.                 int ret = user_login(connfd, db);
298.                 if(ID_ERR == ret){
299.                         return ID_ERR;//id不合法
300.                 }else if(PWD_ERR == ret){
301.                         return PWD_ERR;//密码错误
302.                 }else if(GET_ID_ERR == ret){
303.                         return GET_ID_ERR;
304.                 }else if(GET_PWD_ERR == ret){
305.                         return GET_PWD_ERR;
306.                 }
307.                 return ret;
308.         }else{
309.                 return -1;
310.         }
311.         return 0;
312. }
314. int operation(int connfd, sqlite3 *db, int mode, int id){
315.         if(C == mode){
316.                 // 查询
317.                 int ret = check(connfd, db, id);
318.                 if(-1 == ret){
319.                         return -1;
320.                 }else if(Q == ret){
321.                         return Q;
322.                 }
323.                 return 0;
324.         }else if(H == mode){
325.                 // 历史
326.                 if(-1 == history(connfd, db, id))
327.                         return -1;
328.                 return 0;
329.         }
330. }
332. /*------------------------------------------------------------------------*/
333. //服务器初始化
334. int server_init(char *ip, char* port)
335. {
336.         // 创建套接字
337.         int sockfd = socket(AF_INET, SOCK_STREAM, 0);
338.         if(-1 == sockfd){
339.                 perror("socket");
340.                 return -1;
341.         }
342.         // 绑定
343.         struct sockaddr_in addr;
344.         addr.sin_family = AF_INET;
345.         addr.sin_addr.s_addr = inet_addr(ip);
346.         addr.sin_port = htons(atoi(port));
347.         if(-1 == bind(sockfd, (struct sockaddr *)&addr, sizeof(addr))){
348.                 perror("connect");
349.                 return -1;
350.         }
351.         // 监听
352.         if(-1 == listen(sockfd, 10)){
353.                 perror("listen");
354.                 return -1;
355.         }
356.         printf("----------------服务启动!----------------\n");
357.         printf("---          等待客户端连接           ---\n");
358.         return sockfd;
359. }

复制代码

2.5 客户端 client.c

1. // -------------------------Client---------------------------
2. #include "tool.h"
4. int main(int argc, char *argv[]){
6.         // 判断运行指令合法性
7.         if(3 != argc){
8.                 printf("Input like: %s IP port\n", argv[0]);
9.                 return -1;
10.         }
11.         // 创建套接字
12.         int sockfd = socket(AF_INET, SOCK_STREAM, 0);
13.         if(-1 == sockfd){
14.                 perror("socket");
15.                 return -1;
16.         }
17.         // 连接服务器
18.         struct sockaddr_in addr;
19.         addr.sin_family = AF_INET;
20.         addr.sin_addr.s_addr = inet_addr(argv[1]);
21.         addr.sin_port = htons(atoi(argv[2]));
22.         if(-1 == connect(sockfd, (struct sockaddr *)&addr, sizeof(addr))){
23.                 perror("connect");
24.                 return -1;
25.         }
27.         while(1){
28.                 /*---------------------帐号操作----------------------*/
29.                 long mode = 0;        //用户模式数
30.                 int ret = 0;        //接收各种函数返回结果
31.                 char ui[512] = {0};//接收UI
32.                 char buf[128] = {0};//存储信息
34.                 // 调用帐号UI
35.                 UI_account();
37.                 // 发送mode
38.                 printf("输入您的模式选择数：\n");
39.                 scanf("%ld", &mode);
40.                 getchar();
41.                 send(sockfd,(void*)&mode, sizeof(mode), 0);
43.                 if(R == mode){
44.                         /*-----------------------注册---------------------*/
45.                         int id, pwd;
46.                         printf("输入您要注册的用户id(需至少为两位数)\n");
47.                         scanf("%d", &id);
48.                         send(sockfd, (void*)&id, sizeof(id), 0);
50.                         printf("输入您的密码\n");
51.                         scanf("%d", &pwd);
52.                         send(sockfd, (void*)&pwd, sizeof(pwd), 0);
53.                         printf("您的 id:%d pwd: %d\n", id, pwd);
55.                         recv(sockfd, (void*)&id, sizeof(id), 0); //接收回复
56.                         if(0 == id){
57.                                 printf("注册成功\n");
58.                                 continue;
59.                         }else if(-1 == id){
60.                                 printf("注册失败\n");
61.                                 continue;
62.                         }else if(ID_ERR == id){
63.                                 printf("用户已存在\n");
64.                                 continue;
65.                         }
66.                 }else if(L == mode){
67.                         /*-----------------------登陆---------------------*/
68.                         int id, pwd;
69.                         printf("输入登陆的用户id(需至少为两位数)\n");
70.                         scanf("%d", &id);
71.                         send(sockfd, (void*)&id, sizeof(id), 0);
73.                         printf("输入密码\n");
74.                         scanf("%d", &pwd);
75.                         send(sockfd, (void*)&pwd, sizeof(pwd), 0);
77.                         recv(sockfd, &id, sizeof(id), 0); //接收回复
78.                         if(-1 == id){
79.                                 printf("登陆失败\n");
80.                                 continue;
81.                         }else if(0 == id){
82.                                 printf("您不能以 0 为用户名\n");
83.                                 continue;
84.                         }else if(GET_ID_ERR == id){
85.                                 printf("获取id失败\n");
86.                                 continue;
87.                         }else if(GET_PWD_ERR == id){
88.                                 printf("获取pwd失败\n");
89.                                 continue;
90.                         }else if(ID_ERR == id){
91.                                 printf("用户id不合法\n");
92.                                 continue;       
93.                         }else if(PWD_ERR == id){
94.                                 printf("密码错误\n");
95.                                 continue;       
96.                         }else if(9 < id){
97.                                 /*-------------------登陆成功, 查询开始--------------------*/
98.                                 while(1){
99.                                         // 调用查询UI
100.                                         UI_check();
102.                                         // 发送mode
103.                                         printf("输入查询模式选择数：\n");
104.                                         scanf("%ld", &mode);
105.                                         getchar();
106.                                         send(sockfd, (void*)&mode, sizeof(mode), 0);
107.                                         if(C == mode){
108.                                                 /*----------------------查询-----------------------*/       
109.                                                 //发送单词信息,输入的是Q则退出,当然Q也要发给服务器
110.                                                 printf("输入您要查询的单词,输入 Q 退出\n");
111.                                                 fgets(buf, sizeof(buf), stdin);
112.                                                 send(sockfd, buf, strlen(buf)-1, 0);
113.                                                 if(0 == strncmp(buf, "Q", 1)){
114.                                                         break;
115.                                                 }
116.                                                 memset(buf, 0, sizeof(buf));
117.                                                 //接受结果       
118.                                                 char result[64] = {0};
119.                                                 recv(sockfd, result, sizeof(result), 0);
120.                                                 printf("%s\n", result);
121.                                                 continue;
122.                                         }else if(H == mode){
123.                                                 while(1){
124.                                                         char buf[128] = {0};
125.                                                         int ret = recv(sockfd, buf, sizeof(buf), 0);
126.                                                         if(-1 == ret){
127.                                                                 perror("history recv");
128.                                                                 break;
129.                                                         }else if(0 == ret){
130.                                                                 printf("客户端退出\n");
131.                                                                 break;
132.                                                         }
133.                                                         // 查询成功
134.                                                         printf("%s", buf);
135.                                                         // 历史数据读取完成
136.                                                         if(0 == strncmp(buf, "DONE!", 5)){
137.                                                                 printf("\n");
138.                                                                 break;
139.                                                         }else if(0 == strncmp(buf, "NONE!", 5)){
140.                                                                 //暂无历史数据
141.                                                                 printf("\n");
142.                                                                 break;
143.                                                         }
144.                                                 }
145.                                                 continue; //返回查询界面
146.                                         }else{
147.                                                 puts("请输入正确的选项数");
148.                                                 continue;
149.                                         }
150.                                 }
151.                         }
152.                 }
153.         }
154. }

复制代码

2.6 服务器 server.c

1. //                -------------------------Server----------------------------
2. #include "tool.h"
4. /* ----------------------------main------------------------------  */
5. int main(int argc, char *argv[])
6. {
7.         if(3 > argc){
8.                 printf("参数缺失，您至少需要输入三个参数如:\n./server IP port\n");
9.                 puts("");
10.                 printf("第一次运行服务器，需额外输入任意数字:\n./server IP port num\n");
11.                 return -1;
12.         }
14.         // 若输入了模式(第一次运行服务器，没有创建数据库)
15.         if(4 == argc)
16.                 database_init("data.db");
18.         sqlite3* db;
19.         if(0 != sqlite3_open("data.db", &db)){
20.                 printf("data base open: %s\n", sqlite3_errmsg(db));
21.                 return -1;
22.         }
23.         // 初始化服务器,得到监听套接字
24.         int listenfd = server_init(argv[1], argv[2]);       
25.         if(-1 == listenfd)
26.                 return -1;
28.         /*---------               子进程处理用户交互              ----------*/
30.         /*-----------------一个连接一个进程--------------------*/
31.         while(1){
32.                 long mode = 0;// 接收用户模式
33.                 int ret = 0;//接受一些函数的运行结果
34.                 struct sockaddr_in client;
35.                 socklen_t len = sizeof(client);
36.                 int connfd = accept(listenfd, (struct sockaddr*)&client, &len);
37.                 if(-1 == connfd){
38.                         perror("connect");
39.                         return -1;
40.                 }
41.                 puts("客户端连接成功！");
43.                 pid_t pid = fork();
44.                 if(-1 == pid){
45.                         perror("fork");
46.                         return -1;
47.                 }else if(0 == pid){
48.                         while(1){
49.                                 /* --------------------- 帐号操作 ----------------------*/
50.                                 // 用户登陆操作信息
51.                                 ret = recv(connfd, (void*)&mode, sizeof(mode), 0);
52.                                 if(-1 == ret){
53.                                         perror("recv mode");
54.                                         break;
55.                                 }else if(0 == ret){
56.                                         printf("客户端退出\n");
57.                                         break;
58.                                 }
59.                         /* ------------------帐号操作 --------------------*/
60.                                 // 帐号函数，登陆成功返回登陆id
61.                                 int id = account(connfd, db, mode);
62.                                 send(connfd, (void*)&id, sizeof(id), 0);//发送account的结果
63.                                 if(9 < id){
64.                                         /* ------------------ 登陆成功开始查询 --------------------*/
65.                                         while(1){
66.                                                 // 接收mode
67.                                                 if(-1 == recv(connfd, (void*)&mode, sizeof(mode),0)){
68.                                                         perror("recv mode:");
69.                                                         exit(-1);
70.                                                 }else if(0 == ret){
71.                                                         printf("客户端退出\n");
72.                                                         exit(-1);
73.                                                 }
74.                                                 int ret = operation(connfd, db, mode, id);
75.                                                 if(-1 == ret){
76.                                                         break;
77.                                                 }else if(0 == ret){
78.                                                         continue;
79.                                                 }else if(Q == ret){
80.                                                         break;
81.                                                 }
82.                                         }
83.                                 }
84.                         }
85.                 }
86.                 close(connfd);
87.         }
88.         /* -------------------------- 父进程 ------------------------------*/
89.         wait(NULL);
90.         close(listenfd);
91.         sqlite3_close(db);
92.         exit(0);
93. }

复制代码

---

制作者名单

      

       文案：張嘉鑫       视图：張嘉鑫       代码：張嘉鑫       其余图片：来自网络       特殊鸣谢：李伟老师   

---

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。