当前位置：Linux教程 - Linux - 利用TCP的带外数据来控制远程服务器端的连接

利用TCP的带外数据来控制远程服务器端的连接

http://www.cnhonker.net

http://www.cnhonker.net.

#include
#include
#include
#include
#include "inet.h"

#define MAXSIZE 10240
#define max(a,b) (a)>(b)?(a):(b)
#define TIMEOUT 300
#define CONNECTNUM 5

extern int create_socket();
extern int create_serv();
extern int client_connect();

//定义连接内网机器的端口
int portlist[255]={0,21,22,23,25,53,79,80,110,111,119,139,143,389,513,514,515,1080,1433,3389};
//定义在服务器端监听的端口
int portlist2[255]={0,4444,5555,6666,7777,8888,9999,4446,4447,4448,4449,5500,3389};
//定义需要连接内网机器的IP.域名也可以.
char *hostlist[255]={"","192.168.0.1","192.168.0.2","192.168.0.3"};
//第一个数据都为空是为了方便远程结束服务器段的执行.:0
int remotefd=0,oob,su=0,svfd=0,check_fd=0;
int portnum_listen,hostnum,portnum_connect;
main(int argc,char **argv)
{
　int localp,remotep,size;
　struct sockaddr_in remote_client;
　struct sockaddr_in sock;
　struct timeval time_out;
　void get_oob(int signo);
　char buffer;
　int num=0,portnum;
　pthread_t thread1;
　
　void out2in();
　void setfail();
　//这里的监听端口是用来和发送带外数据的客户端程序连接所用到的.
　if(argc<2){printf("usage:%s \n",argv[0]);exit(0);}
　
　localp=atoi(argv[1]);
　if(!(svfd=create_socket()))exit(0);
　if(!create_serv(svfd,localp))exit(0);
　
　printf("#################################################################\n");
　printf("####### server_convert socket bye bkbll([email protected])######\n");
　printf("########### (H.U.C) http://www.cnhonker.net 2001-9-20 ###########\n\n");
　
　for(;;)
　 {
　　 size=sizeof(struct sockaddr);
　　 printf("\nwaiting for client connecting........\n");
　　 if((remotefd=accept(svfd,(struct sockaddr *)&remote_client,&size))<0){printf("accept error\n");continue;}
　　 printf("accept a client on %d from %s\n",localp,inet_ntoa(remote_client.sin_addr));　
　　
　　 check_fd=0;
　　 time_out.tv_sec=6;
　　 time_out.tv_usec=0;
　　 setsockopt(remotefd,SOL_SOCKET,SO_RCVTIMEO,&time_out,sizeof(time_out));
　　 //设置套接字的owner.
　　 fcntl(remotefd,F_SETOWN,getpid());
　　 //捕获SIGURG信号,读取带外数据
　　 signal(SIGURG,&get_oob);
　　 //捕获SIGALRM信号,在发送带外数据客户端以外结束连接后能保证程序不被无限阻塞.
　　 signal(SIGALRM,&setfail);
　　 for(num=0;num<3;num++){
　　 fprintf(stderr,"waiting for MSG_OOB data%d........",num);
　　 //设置6秒超时.
　　 alarm(6);
　　 while(!su);
　　 if(num==0){portnum_listen=oob;}
　　 if(num==1){hostnum=oob;}
　　 if(num==2){portnum_connect=oob;}
　　 su=0;
　　 alarm(0);
　　 }
　　 printf("portnum_listen=%d,hostnum=%d,portnum_connect=%d\n",portnum_listen,hostnum,portnum_connect);
　　 if((portnum_listen==0)&&(hostnum==0)&&(portnum_connect==0)){close(remotefd);printf("shutdown.:)\n");break;}
　　 if(check_fd==1){continue;}
　　 close(remotefd);
　　 printf("Creating a thread for converting socket.listenport:%d,connect host|port:%s:%d,\n",portlist2[portnum_listen],hostlist[hostnum],portlist[portnum_connect]);
　　 //创建一个线程用来建立指定的监听端口,连接指定IP和端口的socket通道
　　 pthread_create(&thread1,NULL,(void *)&out2in,NULL);
　　 sleep(5);
　 }
close(svfd);　
}

void get_oob(int signo)
{
　//接受带外数据
　if(recv(remotefd,&oob,1,MSG_OOB)<0)
　{
　　fprintf(stderr,"get error:%s\n",strerror(errno));
　　return;
　}
　fprintf(stderr,"successed,MSG_OOB=%d\n",oob);
　su=1;
　return;
}

void setfail()
{
　//超时则结束连接
　su=1;
　check_fd=1;
　return;
}

void out2in()
{
　int out_fd,in_fd,serverd;
　int listenport2,port_connect,maxfd,re_bind=1;
　char host[15];
　struct timeval timeset;
　struct sockaddr_in clientaddr;
　fd_set readfd,writefd;
　int result,i=0,sizelen;
　char read_in1[MAXSIZE],send_out1[MAXSIZE];
　char read_in2[MAXSIZE],send_out2[MAXSIZE];
　int read1=0,totalread1=0,send1=0;
　int read2=0,totalread2=0,send2=0;
　int check_num;
　
　listenport2=portlist2[portnum_listen];
　port_connect=portlist[portnum_connect];
　bzero(host,15);
　memcpy(host,hostlist[hostnum],15);
　bzero(read_in1,MAXSIZE);
　bzero(read_in2,MAXSIZE);
　bzero(send_out1,MAXSIZE);
　bzero(send_out2,MAXSIZE);
　timeset.tv_sec=TIMEOUT;
　timeset.tv_usec=0;
　
　sizelen=sizeof(struct sockaddr);
　//创建一个监听端口
　if(!(serverd=create_socket())){return;}
　setsockopt(serverd,SOL_SOCKET,SO_REUSEADDR,&re_bind,sizeof(re_bind));
　if(!create_serv(serverd,listenport2)){close(serverd);return;}
　
　for(check_num=0;check_num 　 fprintf(stderr,"the %d time,listening on %d.....",check_num,listenport2);
　 //接受外界连接
　 if((out_fd=accept(serverd,(struct sockaddr *)&clientaddr,&sizelen))<0){printf("accept error\n");break;}
　 printf("accept a client from %s\n",inet_ntoa(clientaddr.sin_addr));　
　 //连接内网机器指定端口
if(!(in_fd=create_socket())){close(out_fd);break;}
　 if(!client_connect(in_fd,host,port_connect)){close(in_fd);close(out_fd);break;}
　
　 maxfd=max(out_fd,in_fd)+1;
　
　 while(1)
　 {
　 FD_ZERO(&readfd);
　 FD_ZERO(&writefd);
　
　 FD_SET(out_fd,&readfd);
　　　 FD_SET(in_fd,&writefd);
　 FD_SET(out_fd,&writefd);
　 FD_SET(in_fd,&readfd);
　
　 result=select(maxfd,&readfd,&writefd,NULL,×et);
　 if(result<0){printf("select error\n");break;}
　 else if(result==0){printf("time out\n");break;}
　 if(FD_ISSET(out_fd,&readfd))
　　 {
　　　 read1=recv(out_fd,read_in1,MAXSIZE,0);
　 if(read1==0)break;
　 if(read1<0){printf("read data error:%s\n",strerror(errno));break;}
　　　　　 memcpy(send_out1+totalread1,read_in1,read1);
　　　　　 totalread1+=read1;
　　　　　 bzero(read_in1,MAXSIZE);
　　　　 }
　 if(FD_ISSET(in_fd,&writefd))
　　 {
　　　 while(totalread1>0)
　　　 {
　　　 send1=write(in_fd,send_out1,totalread1);
　　　 if(send1==0)break;
　　　 if(send1<0){printf("unknow error:%s\n",strerror(errno));continue;}
　　　 totalread1-=send1;
　　　 }
　　　　 bzero(send_out1,MAXSIZE);
}
　　　 if(FD_ISSET(in_fd,&readfd))
　　 {
　　　 read2=recv(in_fd,read_in2,MAXSIZE,0);
　 if(read2==0)break;
　 if(read2<0){printf("read data error:%s\n",strerror(errno));break;}
　　　　　 memcpy(send_out2+totalread2,read_in2,read2);
　　　　　 totalread2+=read2;
　　　　　 bzero(read_in2,MAXSIZE);
　　　　 }
　 if(FD_ISSET(out_fd,&writefd))
　　 {
　　　 while(totalread2>0)
　　　 {
　　　 send2=write(out_fd,send_out2,totalread2);
　　　 if(send2==0)break;
　　　 if(send2<0){printf("unknow error:%s\n",strerror(errno));continue;}
　　　 totalread2-=send2;
　　　 }
　　　　 bzero(send_out2,MAXSIZE);
}
　 }　　
　 close(out_fd);
　 close(in_fd);
　}
　close(serverd);
　return;
}

/* http://www.cnhonker.net 　Sep 19,2001*/

下面是发送带外数据的客户端程序.
/*use tcp OOB sign to select port and host for connecting.
powerd by bkbll([email protected])
welcome to visite our website:http://www.cnhonker.net.
tested in Redhat 6.2(kernel:2.2.14 on i386)
*/
#include
#include
#include
#include "inet.h"

extern int create_socket();
extern int create_serv();
extern int client_connect();

main(int argc,char **argv)
{
int sockfd;
int listp,inhost,inhostp,a;
int byte;
char b;
/*发送带外数据到指定的IP和端口.第一个host表示我们的服务器端软件的IP,第二个port表示服务器端软件的端口.
第三个port是表示我们希望在目标服务器上建立的监听端口,第四个host表示我们希望服务器端软件连接的内网机器IP
最后一个port表示希望连接内网机器的端口.
注意:后三个数据都是小与256的int型数据,比如:1 2 3或者4 5 6等等。.发送0 0 0 表示结束远程服务器端程序.
*/
if(argc<6){printf("Usage:%s \n",argv[0]);exit(0);}
listp=atoi(argv[3]);
inhost=atoi(argv[4]);
inhostp=atoi(argv[5]);
b=a;

printf("#################################################################\n");
printf("######### remote control server connect client bye bkbll ########\n");
printf("########### (H.U.C) http://www.cnhonker.net 2001-9-20 ###########\n\n");
if(!(sockfd=create_socket()))exit(0);
if(!client_connect(sockfd,argv[1],atoi(argv[2]))){close(sockfd);exit(0);}
//?
write(sockfd,&b,1);
sleep(1);
//发送第一个带外数据
if((byte=send(sockfd,&listp,1,MSG_OOB))<0){printf("send MSG_OOB error1:%s\n",strerror(errno));}
printf("send success,data:%d,total %d byte\n",listp,byte);
sleep(1);
//发送第二个带外数据
if((byte=send(sockfd,&inhost,1,MSG_OOB))<0){printf("send MSG_OOB error2:%s\n",strerror(errno));}
printf("send success,data:%d,total %d byte\n",inhost,byte);
sleep(1);
//发送第三个带外数据.
if((byte=send(sockfd,&inhostp,1,MSG_OOB))<0){printf("send MSG_OOB error3:%s\n",strerror(errno));}
printf("send success,data:%d,total %d byte\n",inhostp,byte);
sleep(1);

close(sockfd);
}

发布人:netbull 来自:红客联盟

站点导航

赞助商链接