找回密碼
 立即注冊(cè)

QQ登錄

只需一步，快速開始

搜索
查看: 4623|回復(fù): 0
收起左側(cè)

在線電子詞典項(xiàng)目C語(yǔ)言源碼

[復(fù)制鏈接]
ID:390263 發(fā)表于 2018-8-26 23:55 | 顯示全部樓層 |閱讀模式
邏輯清晰，框架規(guī)范的在線電子詞典源程序
0.png

C語(yǔ)言源程序如下:
  1. #include <stdio.h>
  2. #include <string.h>
  3. #include <sqlite3.h>
  4. #define MAXLEN_DATA 256

  6. int main ()
  7. {
  8.     char buff[MAXLEN_DATA]={0};
  9.     FILE *fp;
  10.     int i= 0;
  11.     char word[35]="\0";
  12.     char *p;
  13.     char meaning[256];
  14.     char sql_cmd[128];
  15.     char *errmsg;
  16.     sqlite3 *db;

  18.     /*查找單詞*/
  19.     if ((fp = fopen("dict.txt", "r")) == NULL)
  20.     {
  21.         perror("fail to open");
  22.         return -1;
  23.     }



  27.     if( sqlite3_open("wmk.db", &db) != SQLITE_OK)
  28.     {
  29.         printf("fail to open %s\n",sqlite3_errmsg(db));

  31.     }


  34.     while (fgets(buff, MAXLEN_DATA, fp) != NULL)
  35.     {
  36.         i= 0;
  37.         p= buff;
  38.         while (*p != ' ')
  39.         {
  40.             word[i] = *p;
  41.             i++;
  42.             p++;
  43.             continue;//跳過第一個(gè)單詞
  44.         }
  45.         word[i] = '\0';
  46.         while (*(++p) == ' ')
  47.         {
  48.             continue;//跳過單詞后面的空格
  49.         }
  50.         strcpy(meaning,p);
  51.         sprintf(sql_cmd,"insert into word values('%s','%s')",word,meaning);
  52.         if(sqlite3_exec(db, sql_cmd,NULL,NULL,&errmsg) != SQLITE_OK)
  53.         {
  54.             printf("fail exec\n");
  55.         }

  57.     }
  58.     if( sqlite3_close(db) != SQLITE_OK)
  59. {
  60.     printf("fail to close %s\n",sqlite3_errmsg(db));
  61.    
  62. }
  63. return 0;
  64. }
復(fù)制代碼
  1. /*************************************************************************
  2. > File Name: dict_server.c
  3. > Author: WangMingkai
  4. > Created Time: Sun 22 Apr 2018 06:40:59 PM CST
  5. ************************************************************************/

  7. #include<stdio.h>
  8. #include<stdlib.h>
  9. #include<string.h>
  10. #include<sys/types.h>
  11. #include<sys/stat.h>
  12. #include<fcntl.h>
  13. #include<sys/socket.h>
  14. #include<unistd.h>
  15. #include<netinet/in.h>
  16. #include<arpa/inet.h>
  17. #include<sqlite3.h>
  18. #include<signal.h>
  19. #include<time.h>
  20. #include<pthread.h>
  21. #include<time.h>



  25. //定義用戶數(shù)據(jù)結(jié)構(gòu)體
  26. struct message_user
  27. {
  28.     char name[24];
  29.     char password[24];
  30.     char telephone[24];
  31.     char address[24];
  32.        
  33.     char word[18];
  34.     char meaning[256];
  35.        
  36.     char record[48][24];//存放查找結(jié)果內(nèi)容的數(shù)組
  37.     char head[6][24]; //存放查找結(jié)果字段名稱的數(shù)組
  38.        
  39.     int state;  //用戶在線狀態(tài)
  40.     int nrow;   //數(shù)據(jù)庫(kù)函數(shù)執(zhí)行后得到記錄的數(shù)目
  41.     int ncolumn;//數(shù)據(jù)庫(kù)函數(shù)執(zhí)行后得到字段的數(shù)目
  42.        
  43.     int flag;   //客戶端發(fā)送的命令
  44.        
  45.     int err;    //判斷執(zhí)行數(shù)據(jù)庫(kù)函數(shù)后是否成功
  46.        
  47.     int binary; //判斷查詢歷史記錄的方式，0/姓名，1/單詞
  48.        
  49.     int update; //修改個(gè)人信息選項(xiàng)，0/密碼，1/電話，2/地址
  50. };
  51. typedef struct message_user Mess_user;

  53. char buffer1[256]={0};
  54. int fd;

  56. time_t timep;
  57. //使用多線程來實(shí)現(xiàn)并發(fā)服務(wù)器
  58. void *fun_pthread(void *arg)
  59. {

  61.     int  accept_sock_fd = *(int *)arg;
  62.     int addrlen;
  63.     Mess_user user;
  64.     char word[18] = {0};
  65.     char sql_cmd1[128] = {0};
  66.     char sql_cmd2[128] = {0};
  67.     time_t t;
  68.     int flag;
  69.     free(arg);
  70.     char buff[128];
  71.     char time_c[30];
  72.    
  73.     int num = 1;
  74.     int i, j, index;

  76.     char **resultp;
  77.     int nrow, ncolumn;

  79.     sqlite3 *db;
  80.     char *errmsg;

  82.     //打開sqlite3數(shù)據(jù)庫(kù)
  83.     if(sqlite3_open("wmk.db", &db) != 0)
  84.     {
  85.         perror("fail open sqlite3");
  86.         exit(-1);
  87.     }

  89.     while(1)
  90.     {

  92.         if(read(accept_sock_fd, &user, sizeof(struct message_user)) == -1)
  93.         {
  94.             perror("fail recv flag");
  95.             exit(-1);
  96.         }
  97.         switch(user.flag)
  98.         {
  99.             case 1:
  100.             //向數(shù)據(jù)庫(kù)中插入用戶名信息
  101.             read(accept_sock_fd, &user, sizeof(struct message_user));
  102.             sprintf(sql_cmd1,"select * from user where name='%s'",user.name);
  103.             if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  104.             {
  105.                 printf("fail exec %s\n",errmsg);
  106.                 exit(-1);
  107.             }
  108.             if(nrow != 0)
  109.             {
  110.                 user.err = 1;
  111.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  112.                 break;
  113.             }
  114.             if(nrow == 0)
  115.             {
  116.                 user.err = 0;
  117.                 write(accept_sock_fd, &user, sizeof(struct message_user));

  119.                 read(accept_sock_fd, &user, sizeof(struct message_user));

  121.                 sprintf(sql_cmd2,"insert into user values ('%s','%s','%s','%s', %d)", user.name, user.password, user.telephone, user.address, user.state);
  122.                
  123.                 if(sqlite3_get_table(db, sql_cmd2, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  124.                 {
  125.                     printf("fail exec %s\n",errmsg);
  126.                     exit(-1);
  127.                 }
  128.                     
  129.                 user.err = 0;
  130.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  131.                 time(&timep);//參數(shù)是能返回 time_t 型對(duì)象 的指針 timer ，那里存放著當(dāng)時(shí)時(shí)間。
  132.                 strcpy(time_c, ctime(&timep));
  133.                 sprintf(buff, "%s用戶%s注冊(cè)\n", time_c, user.name);
  134.                 write(fd, buff, strlen(buff));
  135.                
  136.             }
  137.                 break;

  139.             //用戶開始登錄
  140.             case 2:
  141.             
  142.             read(accept_sock_fd, &user, sizeof(struct message_user));

  144.             sprintf(sql_cmd1,"select * from user where name='%s'",user.name);
  145.             
  146.             if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  147.             {
  148.                
  149.                 printf("fail exec %s\n",errmsg);
  150.                 exit(-1);
  151.             }
  152.             if( nrow == 0 )
  153.             {

  155.                 user.err = 1;
  156.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  157.                 break;
  158.                
  159.             }
  160.             if( nrow == 1)
  161.             {

  163.                 user.err = 0;
  164.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  165.                 while(num != 0)
  166.                 {
  167.                     read(accept_sock_fd, &user, sizeof(struct message_user));

  169.                     sprintf(sql_cmd2,"select password from user where name='%s'",user.name);
  170.                
  171.                     if(sqlite3_get_table(db, sql_cmd2, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  172.                     {
  173.                         printf("fail exec %s\n",errmsg);
  174.                         exit(-1);
  175.                     }
  176.                     num = strcmp(user.password, resultp[ncolumn]);
  177.                     if(num == 0)
  178.                     {
  179.                         user.err = 0;//登錄成功
  180.                         sprintf(sql_cmd1, "update user set state=1 where name='%s'", user.name);
  181.                         sqlite3_exec(db, sql_cmd1, NULL, NULL,&errmsg);
  182.                         time(&timep);
  183.                         strcpy(time_c, ctime(&timep));
  184.                         sprintf(buff, "%s用戶%s登錄\n", time_c, user.name);
  185.                         write(fd, buff, strlen(buff));
  186.                     }
  187.                     if(num != 0)
  188.                     {
  189.                         user.err = 1;//登錄失敗
  190.                     }
  191.                     write(accept_sock_fd, &user, sizeof(struct message_user));

  193.                 }
  194.             }
  195.                 break;

  197.             case 3:
  198.             //開始查找單詞含義，在數(shù)據(jù)庫(kù)中插入查找時(shí)間戳記錄，并把查找結(jié)果發(fā)送給客戶端
  199.             if(read(accept_sock_fd, &user, sizeof(struct message_user)) == -1)
  200.             {
  201.                 perror("fail recv word");
  202.                 exit(-1);
  203.             }
  204.             sprintf(sql_cmd1,"select meaning from word where word='%s'",user.word);
  205.                
  206.             if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  207.             {
  208.                 printf("fail exec %s\n",errmsg);
  209.                 exit(-1);
  210.             }
  211.             if(nrow == 0)
  212.             {
  213.                 user.err = 1;   
  214.                 write(accept_sock_fd, &user,sizeof(struct message_user));
  215.                 break;
  216.             }
  217.             if(nrow != 0)
  218.             {
  219.                 strcpy(user.meaning, resultp[ncolumn]);
  220.                 user.err = 0;
  221.                 write(accept_sock_fd, &user,sizeof(struct message_user));
  222.                 sprintf(sql_cmd1, "insert into record values ('%s','%s')", user.name, user.word);
  223.                 if(sqlite3_exec(db,sql_cmd1, NULL, NULL, &errmsg) != 0)
  224.                 {
  225.                     printf("fail ecec %s\n",errmsg);
  226.                     exit(-1);
  227.                 }
  228.                 time(&timep);
  229.                 strcpy(time_c, ctime(&timep));
  230.                 sprintf(buff, "%s用戶%s查找單詞%s\n", time_c, user.name, user.word);
  231.                 write(fd, buff, strlen(buff));
  232.             
  233.                 break;
  234.             }
  235.             case 4:
  236.                 //查找歷史記錄
  237.             read(accept_sock_fd, &user, sizeof(struct message_user));
  238.             if(user.binary == 0)
  239.             {
  240.                 sprintf(sql_cmd1,"select word from record where name='%s'",user.name);
  241.             }
  242.             if(user.binary == 1)
  243.             {
  244.                 sprintf(sql_cmd1,"select name from record where word='%s'",user.word);
  245.             }
  246.             if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  247.             {
  248.                 printf("fail exec %s\n",errmsg);
  249.                 exit(-1);
  250.             }
  251.             if( nrow == 0 )
  252.             {
  253.                 user.err = 1;
  254.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  255.                 break;
  256.             }
  257.             if( nrow != 0)
  258.             {
  259.                 user.err = 0;
  260.                 j = ncolumn;
  261.                 for(i = 0; i < nrow; i++)
  262.                 {
  263.                     strcpy(user.record[i], resultp[j++]);
  264.                 }
  265.                 user.nrow = nrow;
  266.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  267.                 time(&timep);
  268.                 strcpy(time_c, ctime(&timep));
  269.                 sprintf(buff, "%s用戶%s查看歷史記錄\n", time_c, user.name);
  270.                 write(fd, buff, strlen(buff));
  271.                
  272.             }
  273.                 break;
  274.             case 5:
  275.                 //查看個(gè)人信息
  276.             read(accept_sock_fd, &user, sizeof(struct message_user));
  277.             sprintf(sql_cmd1, "select * from  user  where name='%s'", user.name);
  278.             sqlite3_exec(db, ".header on", NULL, NULL, &errmsg);
  279.             sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg);
  280.             sqlite3_exec(db, ".header off", NULL, NULL, &errmsg);

  282.             if( nrow == 0 )
  283.             {
  284.                 user.err = 1;
  285.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  286.                 break;
  287.             }
  288.             if( nrow != 0)
  289.             {
  290.                 user.err = 0;
  291.                 index = ncolumn;
  292.                 for(i = 0; i < nrow; i++)
  293.                 {
  294.                     for(j = 0; j < ncolumn; j++)
  295.                     {
  296.                         strcpy(user.record[j], resultp[index++]);
  297.                         strcpy(user.head[j], resultp[j]);

  299.                     }
  300.                 }
  301.                 user.nrow = nrow;
  302.                 user.ncolumn = ncolumn;
  303.                 write(accept_sock_fd, &user, sizeof(struct message_user));
  304.                 time(&timep);
  305.                 strcpy(time_c, ctime(&timep));
  306.                 sprintf(buff, "%s用戶%s查看個(gè)人信息\n", time_c, user.name);
  307.                 write(fd, buff, strlen(buff));
  308.                
  309.             }
  310.                

  312.                 break;
  313.             case 6:
  314.                 //修改個(gè)人信息
  315.                 read(accept_sock_fd, &user, sizeof(struct message_user));
  316.                 if(user.update == 0)
  317.                 {
  318.                     
  319.                     sprintf(sql_cmd1,"select password from user where name='%s'",user.name);
  320.                     sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg);
  321.                     num = strcmp(user.password, resultp[ncolumn]);
  322.                     if(num != 0)
  323.                     {
  324.                         user.nrow = 0;
  325.                         write(accept_sock_fd, &user, sizeof(struct message_user));
  326.                         break;
  327.                     }
  328.                     if(num == 0)
  329.                     {
  330.                         user.nrow = 1;
  331.                         write(accept_sock_fd, &user, sizeof(struct message_user));
  332.                         read(accept_sock_fd, &user, sizeof(struct message_user));
  333.                         
  334.                         sprintf(sql_cmd2,"update user set password='%s' where name='%s'", user.password, user.name);
  335.                         if(sqlite3_get_table(db, sql_cmd2, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  336.                         {
  337.                             user.err = 1;
  338.                         }
  339.                         else
  340.                             user.err = 0;
  341.                         write(accept_sock_fd, &user, sizeof(struct message_user));
  342.                         time(&timep);
  343.                         strcpy(time_c, ctime(&timep));
  344.                         sprintf(buff, "%s用戶%s修改個(gè)人密碼為%s\n", time_c, user.name, user.password);
  345.                         write(fd, buff, strlen(buff));
  346.                         break;
  347.                         
  348.                     }
  349.                 }
  350.                 if(user.update == 1)
  351.                 {
  352.                     sprintf(sql_cmd1,"update user set telephone='%s' where name='%s'", user.telephone, user.name);
  353.                     if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  354.                     {
  355.                         user.err = 1;
  356.                     }
  357.                     else
  358.                         user.err = 0;
  359.                     write(accept_sock_fd, &user, sizeof(struct message_user));
  360.                     time(&timep);
  361.                     strcpy(time_c, ctime(&timep));
  362.                     sprintf(buff, "%s用戶%s修改個(gè)人電話為%s\n", time_c, user.name, user.telephone);
  363.                     write(fd, buff, strlen(buff));
  364.                     break;
  365.                         
  366.                 }
  367.                 if(user.update == 2)
  368.                 {
  369.                     sprintf(sql_cmd1,"update user set address='%s' where name='%s'", user.address, user.name);
  370.                     if(sqlite3_get_table(db, sql_cmd1, &resultp, &nrow, &ncolumn, &errmsg) != 0)
  371.                     {
  372.                         user.err = 1;
  373.                     }
  374.                     else
  375.                         user.err = 0;
  376.                     write(accept_sock_fd, &user, sizeof(struct message_user));
  377.                     time(&timep);
  378.                     strcpy(time_c, ctime(&timep));
  379.                     sprintf(buff, "%s用戶%s修改個(gè)人地址為%s\n", time_c, user.name, user.address);
  380.                     write(fd, buff, strlen(buff));
  381.                     break;
  382.                 }
  383.                
  384.             case 0:
  385.                 //關(guān)閉數(shù)據(jù)
  386.                 read(accept_sock_fd, &user, sizeof(struct message_user));
  387.                 sprintf(sql_cmd1, "update user set state=0 where name='%s'", user.name);
  388.                 sqlite3_exec(db, sql_cmd1, NULL, NULL,&errmsg);
  389.                 time(&timep);
  390.                 strcpy(time_c, ctime(&timep));
  391.                 sprintf(buff, "%s用戶%s退出\n", time_c, user.name);
  392.                 write(fd, buff, strlen(buff));
  393.                 break;
  394.         }
  395.         if(user.flag == 0)
  396.             break;
  397.     }
  398.     sqlite3_close(db);
  399.     pthread_exit(NULL);
  400. }

  402. //管理員模式顯示所有用戶
  403. void fun_admin_show(sqlite3 *db)
  404. {
  405.    
  406.     char *errmsg, **resultp;
  407.     int nrow, ncolumn, i, j, index;

  409.     if(sqlite3_get_table(db, "select * from user", &resultp, &nrow, &ncolumn, &errmsg) != 0)
  410.     {
  411.         printf("fail admin show : %s\n",errmsg);
  412.         return;
  413.     }
  414.     index = ncolumn;
  415.     for(i = 0; i < nrow; i++)
  416.     {
  417.         for(j = 0; j < ncolumn; j++)
  418.         {
  419.             printf("%s:%s\n", resultp[j], resultp[index++]);
  420.         }
  421.         printf("-------------------------------------\n");
  422.     }
  423. }
  424. //管理員模式修改用戶信息
  425. void fun_admin_alter(sqlite3 *db)
  426. {
  427.     char name[24];
  428.     char telephone[24];
  429.     char address[24];
  430.     int alter_cmd;
  431.     char sql[128];
  432.     char *errmsg, **resultp;
  433.     int nrow, ncolumn, i, j, index;

  435.     while(1)
  436.     {
  437.         printf("請(qǐng)輸入您要修改的用戶名：");
  438.         scanf("%s",name);
  439.         sprintf(sql, "select * from user where name='%s'",name);
  440.         sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg);
  441.         if(nrow == 0)
  442.         {
  443.             printf("沒有此用戶,請(qǐng)更換用戶名\n");
  444.         }
  445.         if(nrow != 0)
  446.         {
  447.             while(1)
  448.             {
  449.                 printf("請(qǐng)輸入您要修改的屬性(0/電話，1/地址):");
  450.                 scanf("%d",&alter_cmd);
  451.                 if(alter_cmd > 1 || alter_cmd < 0)
  452.                 {
  453.                     printf("輸入錯(cuò)誤，請(qǐng)重新輸入\n");
  454.                 }
  455.                 else
  456.                 {
  457.                     if(alter_cmd == 0)
  458.                     {
  459.                         printf("請(qǐng)輸入需要更改的新電話號(hào)碼：");
  460.                         scanf("%s",telephone);
  461.                         sprintf(sql, "update user set telephone='%s' where name='%s'", telephone, name);
  462.                         if(sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg) == 0)
  463.                         {
  464.                             printf("更改成功！\n");
  465.                             break;
  466.                         }
  467.                     }
  468.                     if(alter_cmd == 1)
  469.                     {
  470.                         printf("請(qǐng)輸入需要更改的新地址：");
  471.                         scanf("%s",address);
  472.                         sprintf(sql, "update user set address='%s' where name='%s'", address, name);
  473.                         if(sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg) == 0)
  474.                         {
  475.                             printf("更改成功！\n");
  476.                             break;
  477.                         }
  478.                     }

  480.                 }
  481.             }
  482.             break;
  483.             
  484.         }
  485.     }  
  486. }
  487. //管理員模式添加用戶
  488. void fun_admin_add(sqlite3 *db)
  489. {
  490.     char name[24];
  491.     char password[24];
  492.     char telephone[24];
  493.     char address[24];
  494.     int state;
  495.     char sql[128];
  496.     char *errmsg, **resultp;
  497.     int nrow, ncolumn, i, j, index;
  498.    
  499.     while(1)
  500.     {
  501.         printf("請(qǐng)輸入您要添加的用戶名:");
  502.         scanf("%s",name);
  503.         sprintf(sql, "select * from user where name='%s'",name);
  504.         sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg);
  505.         if(nrow == 1)
  506.         {
  507.             printf("該用戶已存在,請(qǐng)更換用戶名\n");
  508.         }
  509.         if(nrow == 0)
  510.         {
  511.             printf("請(qǐng)輸入您的密碼：");
  512.             scanf("%s",password);
  513.             printf("請(qǐng)輸入您的電話：");
  514.             scanf("%s",telephone);
  515.             printf("請(qǐng)輸入您的地址：");
  516.             scanf("%s",address);
  517.             state = 0;
  518.             sprintf(sql, "insert into user values ('%s', '%s', '%s', '%s', %d)", name, password, telephone, address, state);
  519.             if(sqlite3_exec(db, sql, NULL, NULL, &errmsg) == 0)
  520.             {
  521.                 printf("添加成功！");
  522.                 break;
  523.             }
  524.             else
  525.             {
  526.                 printf("添加失敗\n");
  527.             }
  528.         }
  529.     }
  530. }
  531. //管理員刪除用戶
  532. void fun_admin_delete(sqlite3 *db)
  533. {
  534.     char name[24];
  535.     char sql[128];
  536.     char *errmsg, **resultp;
  537.     int nrow, ncolumn;

  539.     while(1)
  540.     {
  541.         printf("請(qǐng)輸入您要?jiǎng)h除的用戶名:");
  542.         scanf("%s", name);
  543.         sprintf(sql, "select * from user where name='%s'",name);
  544.         sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg);
  545.         if(nrow == 0)
  546.         {
  547.             printf("該用戶不存在,請(qǐng)更換用戶名\n");
  548.         }
  549.         if(nrow != 0)
  550.         {
  551.             
  552.             sprintf(sql, "delete from user where name='%s'",name);
  553.             if(sqlite3_get_table(db, sql, &resultp, &nrow, &ncolumn, &errmsg) == 0)
  554.             {
  555.                 printf("刪除用戶成功\n");
  556.                 break;
  557.             }
  558.         }

  560.     }
  561. }

  563. //服務(wù)器的管理員模式
  564. void *fun_admin_pthread()
  565. {
  566.     int f_cmd;
  567.     char name[24];
  568.     char telephone[24];
  569.     char address[24];
  570.     char admin;
  571.     sqlite3 *db;
  572.     if(sqlite3_open("wmk.db", &db) != 0)
  573.     {
  574.         perror("fail open sqlite3");
  575.         exit(-1);
  576.     }

  578.         while(1)
  579.         {
  580.             printf("請(qǐng)按A進(jìn)入管理員模式\n");
  581.             scanf("%c",&admin);
  582.             if(admin == 'A')
  583.             {
  584.                 system("clear");
  585.                 printf("*********************************\n");
  586.                 printf("管理員模式開啟\n");
  587.                 printf("*********************************\n");
  588.                 printf("1:顯示所有用戶信息\n");
  589.                 printf("2:修改用戶信息\n");
  590.                 printf("3:添加用戶\n");
  591.                 printf("4:刪除用戶\n");
  592.                 printf("0:退出\n");
  593.                 printf("*********************************\n");
  594.                 while(f_cmd)
  595.                 {
  596.                     printf("請(qǐng)輸入您要進(jìn)行的操作:");
  597.                     scanf("%d",&f_cmd);
  598.                     if(f_cmd < 0 || f_cmd > 4)
  599.                     {
  600.                         printf("輸入有誤，請(qǐng)重新輸入\n");
  601.                     }
  602.                     switch(f_cmd)
  603.                     {
  604.                         case 1:
  605.                         fun_admin_show(db);
  606.                         break;
  607.                         case 2:
  608.                         fun_admin_alter(db);
  609.                         break;
  610.                         case 3:
  611.                         fun_admin_add(db);
  612.                         break;
  613.                         case 4:
  614.                         fun_admin_delete(db);
  615.                         break;
  616.                         case 0:
  617.                         break;
  618.                     }
  619.                     if(f_cmd == 0)
  620.                     {
  621.                         break;
  622.                     }
  623.                     printf("請(qǐng)按回車鍵繼續(xù):");
  624.                     getchar();
  625.                     while(getchar() != '\n')
  626.                     {
  627.                         ;
  628.                     }
  629.                     system("clear");
  630.                     printf("*********************************\n");
  631.                     printf("管理員模式開啟\n");
  632.                     printf("*********************************\n");
  633.                     printf("1:顯示所有用戶信息\n");
  634.                     printf("2:修改用戶信息\n");
  635.                     printf("3:添加用戶\n");
  636.                     printf("4:刪除用戶\n");
  637.                     printf("0:退出\n");
  638.                     printf("*********************************\n");
  639.                 }
  640.             }
  641.         }
  642. }
  643. int main(int argc, char *argv[])
  644. {
  645.     Mess_user user;


  648.     int sock_fd, accept_sock_fd, addrlen;
  649.     pthread_t pid, f_pid;
  650.     int *fun_sockfd = NULL;

  652.     char word[18] = {0};
  653.     char sql_cmd[128] = {0};
  654.     int flag;

  656.     sqlite3 *db;
  657.     char *errmsg;
  658.    
  659.     fd = open("log.txt", O_RDWR|O_CREAT|O_APPEND, 0666);
  660.    
  661.     struct sockaddr_in server_addr, client_addr;
  662.     memset(&server_addr, 0, sizeof(server_addr));
  663.     server_addr.sin_family = AF_INET;
  664.     server_addr.sin_port = htons(2342);
  665.     server_addr.sin_addr.s_addr = inet_addr("192.168.1.165");

  667.     //創(chuàng)建套接字
  668.     sock_fd = socket(AF_INET, SOCK_STREAM, 0);
  669.     if(sock_fd == -1)
  670.     {
  671.         perror("fail socket");
  672.         exit(-1);
  673.     }

  675.     //綁定套接字
  676.     if(bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1)
  677.     {
  678.         perror("fail bind");
  679.         exit(-1);
  680.     }

  682.     //監(jiān)聽套接字
  683.     if(listen(sock_fd, 4) == -1)
  684.     {
  685.         perror("fail listen");
  686.         exit(-1);
  687.     }
  688.        
  689.         //管理員模式  
  690.         pthread_create(&f_pid, NULL, fun_admin_pthread, NULL);
  691.          
  692.        
  693.     //使用并發(fā)服務(wù)器，可保證多客戶端使用
  694.     while(1)
  695.     {
  696.         memset(&user, 0, sizeof(struct message_user));
  697.         addrlen = sizeof(client_addr);
  698.         accept_sock_fd = accept(sock_fd, (struct sockaddr *)&client_addr,(socklen_t *)&addrlen);
  699.         if(accept_sock_fd == -1)
  700.         {
  701.             perror("fail accept");
  702.             exit(-1);
  703.         }      
  704.         fun_sockfd = (int *)malloc(sizeof(int));
  705.         *fun_sockfd=  accept_sock_fd;

  707.         pthread_create(&pid, NULL, fun_pthread, (void*)fun_sockfd);
  708.         

  710.     }

  712.    
  713.     return 0;
  714. }

復(fù)制代碼


所有資料51hei提供下載:
在線詞典.rar (975.63 KB, 下載次數(shù): 17)


回復(fù)

使用道具 舉報(bào)

本版積分規(guī)則

手機(jī)版|小黑屋|51黑電子論壇 |51黑電子論壇6群 QQ 管理員QQ:125739409;技術(shù)交流QQ群281945664

Powered by 單片機(jī)教程網(wǎng)

快速回復(fù) 返回頂部 返回列表