【我的项目666--智能楼宇门禁】TCP服务器&多线程

donatello1996

    在Linux系统中，TCP通信和多线程应用都是非常常见的，并且也是经常接合使用的，因为TCP中的等待接收操作是阻塞的，倘若不使用多线程，则程序会一直轮询等待信息发过来而不执行下去。这次我，我们用几条简单的C语言语句，实现TCP通信，让板子充当TCP服务器，电脑的上位机程序充当TCP客户端。
    首先是TCP服务器的建立，通过程序代码调用Linux的API：

1.     socklen_t addrsize=sizeof(struct sockaddr);
   
2.     struct sockaddr_in boyaddr;
   
3.     struct sockaddr_in bindaddr;
   
4.     //初始化该结构体变量
   
5.     bzero(&bindaddr,sizeof(bindaddr));
   
6.     bindaddr.sin_family=AF_INET;
   
7.     bindaddr.sin_addr.s_addr=inet_addr(argv[1]);
   
8.     bindaddr.sin_port=htons(atoi(argv[2]));
   
9. 
   
10.     fd_socket=socket(AF_INET,SOCK_STREAM,0);
    
11.     if(fd_socket==-1)
    
12.     {
    
13.             printf("套接字初始化失败!\n");
    
14.             return -1;
    
15.     }
    
16.     ret=bind(fd_socket,(struct sockaddr *)&bindaddr,addrsize);
    
17.     if(ret==-1)
    
18.     {
    
19.             printf("套接字绑定失败!\n");
    
20.             return -1;
    
21.     }
    
22.     ret=listen(fd_socket,5);
    
23.     if(ret==-1)
    
24.     {
    
25.             printf("服务器监听失败!\n");
    
26.             return -1;
    
27.     }
    
28.     newsock=accept(fd_socket,(struct sockaddr *)&boyaddr,&addrsize);
    
29.     if(newsock==-1)
    
30.     {
    
31.             printf("服务器接听失败!\n");
    
32.             return -1;
    
33.     }

复制代码

其中bindaddr.sin_family=AF_INET这行是直接套用的，不需要深究，要使用TCP通信就必须这样做；bindaddr.sin_addr.s_addr=inet_addr(argv[1]);bindaddr.sin_port=htons(atoi(argv[2]))这两行语句是从程序执行目录中获取IP地址和端口号，如程序编译后生成main可执行文件，则

1. ./main 169.254.122.7 6666

复制代码

就是建立IP为169.254.122.7，端口号为6666的TCP服务器。socket(AF_INET,SOCK_STREAM,0)是建立套接字；bind(fd_socket,(struct sockaddr
*)&bindaddr,addrsize)是绑定套接字；listen(fd_socket,5)是监听TCP客户端的连接；accept(fd_socket,(struct sockaddr *)&boyaddr,&addrsize)是接受TCP的客户端的连接，程序会卡在accept()函数中直到有TCP客户端连上。再来看看主函数：

1.     while(1)
   
2.     {
   
3.         bzero(recvbuf,100);
   
4.         recv(newsock,recvbuf,100,0);
   
5.         printf("客户端发来数据：%s\n",recvbuf);
   
6.     }
   

复制代码

由于recv()函数是阻塞的，因此主函数会一直卡在这个地方直到有TCP客户端的信息发过来。然后就是新建TCP信息发送的线程：

1.     pthread_t id1;
   
2.     pthread_create(&id1,NULL,Scanf_Thread,NULL);

复制代码

这段代码表示新建一个名为Scanf_Thread的线程（其实就是函数），用于TCP信息的发送，我们看看新线程是怎么写的：

1. void *Scanf_Thread(void *arg)
   
2. {
   
3.     int len;
   
4.     char *s;
   
5.     while(1)
   
6.     {
   
7.         bzero(s,0);
   
8.         scanf("%d",&len);
   
9.         s=(char *)malloc(len);
   
10.         scanf("%s",s);
    
11.         send(newsock,s,len,0);
    
12.         free(s);
    
13.     }
    
14. }

复制代码

这个线程的函数名必须加*号以表示它返回值是void*的指针函数，我这里设计这个TCP发送线程是不定长发送的，发送长度由用户自定义，先输入int型正整数表示将要发送的信息的长度，再输入字符串信息。程序编译的时候要在后面加-lpthread后缀表示启用多线程：



来看看效果：

阅读全文

技术范儿

-lpthread表示链接线程库

swiftman

签到签到