unix并发技术的学习及在扫描器上的应用二
上一篇并发技术说的是多进程，本来想在那的基础上加进进程间同步和通信，不过暂时还没有掌握到，只能换成多线程来做rp了.
第一部分--基础知识
一.线程概念：
线程是提高代码响应和性能的绝好的手段，其由内核按时间分片进行管理.进程可含多线程，线程间共享内存空间.节省cup时间，减少系统开销.不过要考虑同步问题.
二.相关函数：
1.pthread_create()
pthread_create创建线程
原型为：
#include<pthread.h>
extern int pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routine) (void *), void *arg);
第一个参数为指向线程标识符的指针
第二个参数用来设置线程属性
第三个参数是线程运行函数的起始地址
最后一个参数是运行函数的参数。
如函数start_routine不需要参数，所以最后一个参数设为空指针。
第二个参数为空指针，这样将生成默认属性的线程。
当创建线程成功时，函数返回0，若不为0则说明创建线程失败，常见的错误返回代码为EAGAIN和EINVAL。
前者表示系统限制创建新的线程，例如线程数目过多了；
后者表示第二个参数代表的线程属性值非法。创建线程成功后，新创建的线程则运行参数三和参数四确定的函数，原来的线程则继续运行下一行代码.
2.pthread_join()
pthread_join等待线程结束
原型为：
#include<pthread.h>
int pthread_join (pthread_t thread, void **value_ptr));
第一个参数为被等待的线程标识符
第二个参数为一个用户定义的指针，它可以用来存储被等待线程的返回值。
这个函数是一个线程阻塞的函数，调用它的函数将一直等待到被等待的线程结束为止，当函数返回时，被等待线程的资源被收回.
3.pthread_exit()
pthread_exit退出线程.
原型为：
#include<pthread.h>
extern void pthread_exit(void *value_ptr);
value_ptr参数指向线程退出状态.
无返回值.
第二部分--多线程80banner扫描器的具体实现
一.思路：
1.多ip处理模块(利用二进制方法处理)
处理一个子网ip(vlsm).
转换ip
unsigned long convert_ip(const char *t_addr);
增加掩码
unsinged long add_masking(const char *t_addr,int mask);
转换成整数
char *reverse_int(unsigned long addr);
2.usage提示模块
int usage(char *pro)
{
printf("pthread 80 banner scanner");
printf("input subnet ip");
printf("usage:%s ip/27 /n",pro);
}
3.扫描模块
viod scanip(char sip[20])
4.多进程及处理模块
pthread()
二.实现
/********************************************************************
**pthread 80 banner scanner ver1.0
*
*to complie:
*user$gcc -o 80scaner 80scanner.c
*
*to use:
*user$./80scanner ip/27 (the best input subnet ip otherwise *waste too many system resource )
*
*coded by nightcat
*july 2003*********************************************************************/
/*所要的头文件*/
#include<sys/types.h>
#include<sys/socket.h>
#include<netinet/in.h>
#include<unistd.h>
#include<stdlib.h>
#include<pthread.h>
#include<string.h>
#include<stdio.h>
#include<math.h>
#define BUF_SIZE 20/*声明函数*/
int usage(char *pro);
void scanip(char sip[20]);
unsigned long convert_ip(const char *t_addr);
unsinged long add_masking(const char *t_addr,int mask);
char *reverse_int(unsigned long addr);int main(int argc ,char* argv[])
{
pthread_t pth;
int count;
char scan_ip[20];
char *network,*mask;/*输入参数判断*/
if(argc!=2)
{
usage(argv[0]);
exit(1);
}
/*处理ip*/
network=strtok(agrv[1],"/");
mask=strtok(NULL,"/");
start=convert_ip(network);
end=add_masking(network,atoi(mask));
/*循环扫描*/
for(count=start;count<=end;count++)
{
scan_ip=reverse_int(count);
/*产生线程*/
if(pthread_create(&pth,null,scanip,scan_ip))
{
perror("pthread_create error/n");
exit(1);
}
}
return(0);
}/*用法函数*/
int usage(char *pro)
{
printf("pthread 80 banner scanner/n");
printf("input subnet ip");
printf("usage:%s ip/27 /n",pro);
}/*扫描函数*/
void scanip(char sip[20])
{
struct sockaddr_in addr;
int s;
char buffer[1024];
if((s=socket(AF_INET,SOCK_STREAM,0))<0){
perror("socket error/n");
exit(1);
}
addr.sin_family=AF_INET;
addr.sin_addr.s_addr=inet_addr(sip);
addr.sin_port=htons(80);
if(connect(s,(struct sockaddr *)&addr,sizeof(addr))<0){
perror("connect error");
exit(1);
}
send(s,"HEAD / HTTP/1.0/n/n",17,0);
recv(s,buffer,sizeof(buffer),0);
printf("%s's http version:/n%s",sip,buffer);
close(s);
pthread_exit(null);
}
/*转换ip*/
unsigned long convert_ip(const char *t_addr)
{
int octet1=0;
int octet2=0;
int octet3=0;
int octet4=0;
if(sscanf(t_addr,"%d.%d.%d.%d",&octet1,&octet2,&octet3,&octet4)<1)
{
perror("sscanf error");
}
return((octet1<<24) | (octet2<<16) |(octet3<<8)|octet4);
}
/*增加掩码*/
unsinged long add_masking(const char *t_addr,int mask)
{
if(mask >32 || mask <0)
{
perror("not a valid subnet mask");
}
return((int)pow(2,32-mask)+conert_ip(t_addr)-1);
}
/*转换成整数格式*/
char *reverse_int (unsigned long addr)
{
static char *buffer[BUF_SIZE];
snprintf((char *)buffer,BUF_SIZE,"%d.%d.%d.%d",
(addr & 0xff000000) >> 24,
(addr & 0x00ff0000) >> 16,
(addr & 0x0000ff00) >> 8,
(addr & 0x000000ff));
return((char *) buffer);
}三总结：
其中新学的东西：
1.子网ip的处理方法
2.子网的划分方法
3.多线程的简单应用
4.pow函数的应用
5.位移的应用