kevin/tcp_ip_scan
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

优化分发

Browse Source 
Signed-off-by: fong <wuwenfengmi@outlook.com>
This commit is contained in:
fong
2024-01-29 18:58:54 +08:00
parent cdef5acf4b
commit df2c61b603
5 changed files with 201 additions and 330 deletions
Download Patch File Download Diff File Expand all files Collapse all files
ip_sacaner/scan_run.cpp
+28 -183
View File
@@ -29,35 +29,6 @@ quint32 ipv4str_to_int(const QString& ipstr)
void trytry::run()
{
if (ipint != 0 && ipstr != "")
{
//qDebug()<<ipstr<<":"<<ipint;
QTcpSocket m_socket;
m_socket.connectToHost(ipstr, ipint, QTcpSocket::ReadWrite);
if (m_socket.waitForConnected(timeout))
{
while(*outputbusy);
*outputbusy+=1;
QString temp = QString("%1:%2").arg(ipstr).arg(ipint);
output_list->append(temp);
//qDebug() << ipstr<<":"<< ipint;
//msleep(1);
*outputbusy-=1;
}
m_socket.disconnectFromHost();
m_socket.disconnect();
//while(*barbusy);
//*barbusy+=1;
//str.asprintf("停止 %.3f",((0.0+*nt_bar)/(0.0+*t_bar))*100);
//bt->setText(QString("%1%").arg(((0.0+*nt_bar)/(0.0+*t_bar))*100));
//qDebug()<<*nt_bar<<"/"<<*t_bar;
//*barbusy-=1;
//*now_thread_num-=1;
}
}
dispatch::dispatch()
@@ -66,180 +37,54 @@ dispatch::dispatch()
}
void dispatch::tray(const QString& ipstr, quint32 ipint)
{
//qDebug()<<"thread "<<now_thread_num<<":"<<set_thread_num;
while (now_thread_num> set_thread_num)
{
//qDebug()<<"while "<<now_thread_num<<":"<<set_thread_num;
}
try_telnet=new trytry;
try_telnet->ipstr = ipstr;
try_telnet->ipint = ipint;
try_telnet->timeout = timeout;
try_telnet->output_list = output_list;
try_telnet->now_thread_num = &now_thread_num;
try_telnet->t_bar=t_bar;
try_telnet->nt_bar=nt_bar;
try_telnet->outputbusy=&outputbusy;
try_telnet->barbusy=&barbusy;
//try_telnet->moveToThread(main_thread);
connect(try_telnet,&QThread::started,[=]()
{
now_thread_num+=1;
thread_start_lock=0;
});
connect(try_telnet,&QThread::finished,[=]()
{
now_thread_num-=1;
});
while(thread_start_lock);
try_telnet->start();
thread_start_lock=1;
*nt_bar+=1;
emit dispatch_one();
}
void dispatch::run()
{
//qDebug()<< ui->IP_list->toPlainText();
//the_bar->setValue(20);
//QTcpSocket* m_socket = new QTcpSocket;
QStringList str_ip_list = ip_list->toPlainText().split("\n");
QStringList str_ip_list = ip_list.split("\n");
QStringList str_ips_list;
QStringList str_port_list = port_list->toPlainText().split("\n");
QStringList str_port_list = port_list.split("\n");
QStringList str_ports_list;
quint32 ips_num=0;
quint32 ports_num=0;
QRegExp ex_ipv4 ("^((25[0-5]|2[0-4]\\d|[01]?\\d\\d?)\\.){3}(25[0-5]|2[0-4]\\d|[01]?\\d\\d?)$");
QRegExp ex_ipv4_more("^((25[0-5]|2[0-4]\\d|[01]?\\d\\d?)\\.){3}(25[0-5]|2[0-4]\\d|[01]?\\d\\d?)-((25[0-5]|2[0-4]\\d|[01]?\\d\\d?)\\.){3}(25[0-5]|2[0-4]\\d|[01]?\\d\\d?)$");
QRegExp ex_ipv4_more2("^((25[0-5]|2[0-4]\\d|[01]?\\d\\d?)\\.){3}(25[0-5]|2[0-4]\\d|[01]?\\d\\d?)/(0?[0-9]|1[0-9]|2[0-9]|3[0-2])$");
QRegExp ex_ipv6 ("^([0-9a-fA-F]{1,4}:){7}[0-9a-fA-F]{1,4}$");
QRegExp ex_domain ("^([a-zA-Z0-9]+(-[a-zA-Z0-9]+)*\\.)+[a-zA-Z]{2,}$");
for (int i = 0; i < str_ip_list.size(); ++i)
{
//qDebug() << str_ip_list.at(i);
str_ips_list = str_ip_list.at(i).split("-");
if (str_ips_list.size() > 1)
if(ex_ipv4.exactMatch(str_ip_list.at(i)))
{
qDebug() << str_ip_list.at(i)<<" is ipv4";
}else if(ex_ipv4_more.exactMatch(str_ip_list.at(i)))
{
ips_num=ipv4str_to_int(str_ips_list.at(str_ips_list.size() - 1))-ipv4str_to_int(str_ips_list.at(0))+1;
qDebug() << str_ip_list.at(i)<<" is ipv4_more";
}else if(ex_ipv4_more2.exactMatch(str_ip_list.at(i)))
{
qDebug() << str_ip_list.at(i)<<" is ipv4_more2";
}else if(ex_ipv6.exactMatch(str_ip_list.at(i)))
{
qDebug() << str_ip_list.at(i)<<" is ipv6";
}else if(ex_domain.exactMatch(str_ip_list.at(i)))
{
qDebug() << str_ip_list.at(i)<<" is domain";
}else
{
ips_num+=1;
qDebug() << str_ip_list.at(i)<<" don't know what is thit";
}
}
for (quint32 ii = 0; ii < str_port_list.size(); ii++)
{
str_ports_list = str_port_list.at(ii).split("-");
if (str_ports_list.size() > 1)
{
ports_num=str_ports_list.at(str_ports_list.size() - 1).toInt() -str_ports_list.at(0).toInt()+1;
}
else
{
ports_num+=1;
}
}
*t_bar=ips_num*ports_num;
*nt_bar=0;
outputbusy=0;
\
//qDebug()<<*t_bar;
//*****************************
for (int i = 0; i < str_ip_list.size(); ++i)
{
//qDebug() << str_ip_list.at(i);
str_ips_list = str_ip_list.at(i).split("-");
if (str_ips_list.size() > 1)
{
for (quint32 ips = ipv4str_to_int(str_ips_list.at(0)); ips < ipv4str_to_int(str_ips_list.at(str_ips_list.size() - 1)) + 1; ips++)
{
//qDebug() << ipv4int_to_str(ips);
for (quint32 ii = 0; ii < str_port_list.size(); ii++)
{
str_ports_list = str_port_list.at(ii).split("-");
if (str_ports_list.size() > 1)
{
for (quint32 prots = str_ports_list.at(0).toInt(); prots < str_ports_list.at(str_ports_list.size() - 1).toInt() + 1; prots++)
{
dispatch::tray(ipv4int_to_str(ips), prots);
}
}
else
{
dispatch::tray(ipv4int_to_str(ips), str_ports_list.at(0).toInt());
}
}
}
}
else
{
for (quint32 ii = 0; ii < str_port_list.size(); ii++)
{
str_ports_list = str_port_list.at(ii).split("-");
if (str_ports_list.size() > 1)
{
for (quint32 prots = str_ports_list.at(0).toInt(); prots < str_ports_list.at(str_ports_list.size() - 1).toInt() + 1; prots++)
{
dispatch::tray(str_ips_list.at(0), prots);
}
}
else
{
dispatch::tray(str_ips_list.at(0), str_ports_list.at(0).toInt());
}
}
}
qDebug() << ips_num;
//for (unsigned long a = str_ips_list.at(0).toInt();a< str_ip_list.size()>1? str_ips_list.at(1).toInt()+1: str_ips_list.at(0).toInt()+1;a++)
//{
// qDebug() << a;
//}
}
//sleep(1);
while(now_thread_num);
emit dispatch_finish();
}