0
点赞
收藏
分享

微信扫一扫

unix并发技术的学习及在扫描器上的应用二


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.位移的应用

举报

相关推荐

0 条评论