使用Java开发多线程端口扫描工具(二)

简介:

一 介绍

       这一篇文章是紧接着上一篇文章(http://www.zifangsky.cn/2015/12/使用java开发多线程端口扫描工具/)写的,端口扫描的原理不用多少,我在上一篇文章中已经说过了,至于目的大家都懂得。在这一篇文章里,我主要是对端口扫描工具的继续完善,以及写出一个比较直观的图形界面出来,以方便我们测试使用。界面如下:

wKiom1aQ2C2RsVlsAADA5eOctiQ635.png

       这个工具主要是实现了以下几点功能:(1)两种扫描方式,一种是只扫描常见端口,另一种是设置一个起始和结束端口,依次探测。当然,原理很简单,用for循环就可以了;(2)输入一个域名或者IP后,可以自定义扫描线程,这一点是非常有用的,因为有的服务器是装了360,云锁或者安全狗的,扫描线程过大或许会被封IP。

注:文末我会给出简易的可执行jar文件的下载链接

二 代码实现

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303
304
305
306
307
308
309
310
311
312
313
314
315
316
317
318
319
320
321
322
323
324
325
326
327
328
329
330
331
332
333
334
335
336
337
338
339
340
341
342
343
344
345
346
347
348
349
350
351
352
353
354
355
356
357
358
359
360
361
362
363
364
365
366
367
368
369
370
371
372
373
374
375
376
377
378
379
380
381
382
383
384
385
386
387
388
389
390
391
392
393
394
395
396
397
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
415
416
417
418
419
import  java.awt.BorderLayout;
import  java.awt.Dimension;
import  java.awt.FlowLayout;
import  java.awt.Font;
import  java.awt.GridBagConstraints;
import  java.awt.GridBagLayout;
import  java.awt.GridLayout;
import  java.awt.Toolkit;
import  java.awt.event.ActionEvent;
import  java.awt.event.ActionListener;
import  java.io.IOException;
import  java.net.InetAddress;
import  java.net.InetSocketAddress;
import  java.net.Socket;
import  java.net.SocketAddress;
import  java.net.UnknownHostException;
import  java.util.concurrent.ExecutorService;
import  java.util.concurrent.Executors;
import  java.util.regex.Matcher;
import  java.util.regex.Pattern;
 
import  javax.swing.ButtonGroup;
import  javax.swing.JButton;
import  javax.swing.JFrame;
import  javax.swing.JLabel;
import  javax.swing.JMenu;
import  javax.swing.JMenuBar;
import  javax.swing.JMenuItem;
import  javax.swing.JOptionPane;
import  javax.swing.JPanel;
import  javax.swing.JRadioButton;
import  javax.swing.JScrollPane;
import  javax.swing.JTextArea;
import  javax.swing.JTextField;
import  javax.swing.SwingUtilities;
 
public  class  PortScan  extends  JFrame  implements  ActionListener {
     private  static  final  long  serialVersionUID = 1L;
     private  GridBagLayout gridbag;
     private  GridBagConstraints constraints;
     private  JPanel mainJPanel,panel1,panel1_1,panel1_2,panel2,panel2_2,panel3,panel4,panel5;
     private  ButtonGroup buttonGroup;   //扫描方式组
     private  JRadioButton scanType1,scanType2;   //扫描方式1,扫描方式2
     private  JLabel startJLabel,endJLabel,threadNum;   //起始端口和结束端口 线程数
     private  JLabel progressJLabel,resultJLabel;   //进度和结果
     private  JTextField customPorts,startPort,endPort,customDomain,customThreadNum;   //常见端口,起始和结束端口;自定义域名,自定义线程数
     private  JButton beginJButton;   //开始扫描
     private  JScrollPane progressPane,resultPane;   //进度面板和结果面板
     private  JTextArea progressJtJTextArea,resultJTextArea;   //同上
     
     private  JMenuBar jMenuBar;
     private  JMenu help;
     private  JMenuItem author,contact,version,readme;
     
     private  Font menuFont =  new  Font( "宋体" , Font.LAYOUT_NO_LIMIT_CONTEXT,  14 );   //菜单字体
     private  Font contentFont =  new  Font( "宋体" , Font.LAYOUT_NO_LIMIT_CONTEXT,  16 );   //正文字体
 
     public  PortScan(){
         super ( "多线程端口扫描工具" );
         Dimension screenSize = Toolkit.getDefaultToolkit().getScreenSize();
         setPreferredSize( new  Dimension( 900 600 ));
         int  frameWidth =  this .getPreferredSize().width;   //界面宽度
         int  frameHeight =  this .getPreferredSize().height;   //界面高度
         setSize(frameWidth,frameHeight);
         setLocation((screenSize.width - frameWidth) /  2 ,(screenSize.height - frameHeight) /  2 );
         
         //初始化
         mainJPanel =  new  JPanel();
         panel1 =  new  JPanel();
         panel1_1 =  new  JPanel();
         panel1_2 =  new  JPanel();
         panel2 =  new  JPanel();
         panel2_2 =  new  JPanel();
         panel3 =  new  JPanel();
         panel4 =  new  JPanel();
         panel5 =  new  JPanel();
         buttonGroup =  new  ButtonGroup();
         scanType1 =  new  JRadioButton( "扫描常见端口:" );
         scanType2 =  new  JRadioButton( "扫描一个连续段的端口:" );
         startJLabel =  new  JLabel( "起始端口:" );
         endJLabel =  new  JLabel( "结束端口:" );
         threadNum =  new  JLabel( "线程:" );
         progressJLabel =  new  JLabel( "扫描进度" );
         resultJLabel =  new  JLabel( "扫描结果" );
         customPorts =  new  JTextField( "21,22,23,25,26,69,80,110,"  +
                 "143,443,465,1080,1158,1433,1521,2100,3306,"  +
                 "3389,7001,8080,8081,8888,9080,9090,43958" );
         startPort =  new  JTextField( "20" 10 );
         endPort =  new  JTextField( "9000" 10 );
         customDomain =  new  JTextField( "www.zifangsky.cn" 25 );
         customThreadNum =  new  JTextField( "5" 5 );
         beginJButton =  new  JButton( "开始扫描" );
         progressPane =  new  JScrollPane();
         resultPane =  new  JScrollPane();
         progressJtJTextArea =  new  JTextArea( 18 20 );
         resultJTextArea =  new  JTextArea( 18 20 );
         
         //布局
         buttonGroup.add(scanType1);
         buttonGroup.add(scanType2);
         scanType1.setSelected( true );
         
         gridbag =  new  GridBagLayout();
         constraints =  new  GridBagConstraints();
         constraints.fill = GridBagConstraints.BOTH;
         mainJPanel.setLayout(gridbag);
         
         constraints.gridwidth =  0
         constraints.gridheight =  1 ;
         constraints.weightx =  1 ;  
         constraints.weighty =  0 ;  
         gridbag.setConstraints(scanType1, constraints);
         scanType1.setFont(contentFont);
         mainJPanel.add(scanType1);
         
         gridbag.setConstraints(customPorts, constraints);
         customPorts.setFont(contentFont);
         mainJPanel.add(customPorts);
         
         gridbag.setConstraints(scanType2, constraints);
         scanType2.setFont(contentFont);
         mainJPanel.add(scanType2);
         
         gridbag.setConstraints(panel1, constraints);
         mainJPanel.add(panel1);
         
         gridbag.setConstraints(panel2, constraints);
         mainJPanel.add(panel2);
         
         constraints.weighty =  1 ;
         gridbag.setConstraints(panel3, constraints);
         mainJPanel.add(panel3);
         
         panel1.setLayout( new  FlowLayout(FlowLayout.LEFT, 30 , 5 ));
         panel1.add(panel1_1);
         panel1.add(panel1_2);
         panel1_1.setLayout( new  FlowLayout(FlowLayout.CENTER, 0 , 5 ));
         startJLabel.setFont(contentFont);
         panel1_1.add(startJLabel);
         startPort.setFont(contentFont);
         panel1_1.add(startPort);
         panel1_2.setLayout( new  FlowLayout(FlowLayout.CENTER, 0 , 5 ));
         endJLabel.setFont(contentFont);
         panel1_2.add(endJLabel);
         endPort.setFont(contentFont);
         panel1_2.add(endPort);
         
         panel2.setLayout( new  FlowLayout(FlowLayout.CENTER,  20 5 ));
         customDomain.setFont(contentFont);
         panel2.add(customDomain);
         panel2.add(panel2_2);
         panel2_2.setLayout( new  FlowLayout());
         threadNum.setFont(contentFont);
         panel2_2.add(threadNum);
         customThreadNum.setFont(contentFont);
         panel2_2.add(customThreadNum); 
         beginJButton.setFont(contentFont);
         panel2.add(beginJButton);
         
         panel3.setLayout( new  GridLayout( 1 2 ));
         panel3.add(panel4);
         panel3.add(panel5);
         panel4.setLayout( new  BorderLayout());
         progressJLabel.setFont(contentFont);
         progressJLabel.setHorizontalAlignment(JLabel.CENTER);
         panel4.add(progressJLabel,BorderLayout.NORTH);
         panel4.add(progressPane,BorderLayout.CENTER);
         progressJtJTextArea.setFont(contentFont);
         progressPane.setViewportView(progressJtJTextArea);
         progressJtJTextArea.setEditable( false );
         progressJtJTextArea.setLineWrap( true );
         progressJtJTextArea.setWrapStyleWord( true );
         panel5.setLayout( new  BorderLayout());
         resultJLabel.setFont(contentFont);
         resultJLabel.setHorizontalAlignment(JLabel.CENTER);
         panel5.add(resultJLabel,BorderLayout.NORTH);
         panel5.add(resultPane,BorderLayout.CENTER);
         resultJTextArea.setFont(contentFont);
         resultPane.setViewportView(resultJTextArea);
         resultJTextArea.setEditable( false );
         resultJTextArea.setLineWrap( true );
         resultJTextArea.setWrapStyleWord( true );
         
         //菜单
         jMenuBar =  new  JMenuBar();
         help =  new  JMenu( "帮助" );
         author =  new  JMenuItem( "作者" );
         contact =  new  JMenuItem( "联系方式" );
         version =  new  JMenuItem( "版本号" );
         readme =  new  JMenuItem( "说明" );
         help.setFont(menuFont);
         jMenuBar.add(help);
         author.setFont(menuFont);
         help.add(author);
         contact.setFont(menuFont);
         help.add(contact);
         version.setFont(menuFont);
         help.add(version);
         readme.setFont(menuFont);
         help.add(readme);
             
         add(mainJPanel);
         setJMenuBar(jMenuBar);
         setVisible( true );
         setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
         
         beginJButton.addActionListener( this );
         author.addActionListener( this );
         contact.addActionListener( this );
         version.addActionListener( this );
         readme.addActionListener( this );
     }  
 
     /**
      * 点击事件,根据选择的不同扫描方式,开启不同的线程开始扫描
      * */
     public  void  actionPerformed(ActionEvent e) {
         if (e.getSource() == beginJButton){
             progressJtJTextArea.setText( "" );
             resultJTextArea.setText( "" );
             String domain = getDomainString(customDomain.getText().trim());
             int  threadNumber = Integer.parseInt(customThreadNum.getText().trim());
             if (domain ==  null )
                 return  ;
             if (scanType1.isSelected()){
                 String[] portsString = customPorts.getText().split( "," );
                 //端口转化为int型
                 int [] ports =  new  int [portsString.length];
                 for ( int  i= 0 ;i<portsString.length;i++)
                     ports[i] = Integer.parseInt(portsString[i].trim());
                 //线程池
                 ExecutorService threadPool = Executors.newCachedThreadPool();
                 for  ( int  i =  0 ; i < threadNumber; i++) {
                     ScanThread1 scanThread1 =  new  ScanThread1(domain, ports,
                             threadNumber, i,  800 );
                     threadPool.execute(scanThread1);
                 }
                 threadPool.shutdown();
             }
             else  if (scanType2.isSelected()){
                 int  startPortInt = Integer.parseInt(startPort.getText().trim());
                 int  endPortInt = Integer.parseInt(endPort.getText().trim());
                 
                 ExecutorService threadPool = Executors.newCachedThreadPool();
                 for  ( int  i =  0 ; i < threadNumber; i++) {
                     ScanThread2 scanThread2 =  new  ScanThread2(domain, startPortInt,endPortInt,
                             threadNumber, i,  800 );
                     threadPool.execute(scanThread2);
                 }
                 threadPool.shutdown();
             }  
         }
         else  if (e.getSource() == author){
             JOptionPane.showMessageDialog( this "zifangsky" , "作者:" ,JOptionPane.INFORMATION_MESSAGE);
         }
         else  if (e.getSource() == contact){
             JOptionPane.showMessageDialog( this "邮箱:admin@zifangsky.cn\n"  +
                     "博客:http://www.zifangsky.cn" , "联系方式:" ,JOptionPane.INFORMATION_MESSAGE);
         }
         else  if (e.getSource() == version){
             JOptionPane.showMessageDialog( this "v1.0.0" , "版本号:" ,JOptionPane.INFORMATION_MESSAGE);
         }
         else  if (e.getSource() == readme){
             JOptionPane.showMessageDialog( this "多线程端口扫描工具,两个扫描方式任你选择,你值得拥有!!!" , "说明:" ,JOptionPane.INFORMATION_MESSAGE);
         }
         
     }
     
     class  ScanThread1  implements  Runnable{
         private  String domain;
         private  int [] ports;  // 待扫描的端口的Set集合
         private  int  threadNumber, serial, timeout;  // 线程数,这是第几个线程,超时时间
         
         public  ScanThread1(String domain, int [] ports,  int  threadNumber,  int  serial,
                 int  timeout) {
             this .domain = domain;
             this .ports = ports;
             this .threadNumber = threadNumber;
             this .serial = serial;
             this .timeout = timeout;
         }
 
         public  void  run() {
             int  port =  0 ;
             try  {
                 InetAddress address = InetAddress.getByName(domain);
                 Socket socket;
                 SocketAddress socketAddress;
                 if  (ports.length <  1 )
                     return ;
                 for  (port =  0  + serial; port <= ports.length -  1 ; port += threadNumber) {
                     SwingUtilities.invokeLater( new  ProgressRunnable( ports[port]));   //更新界面
                 
                     socket =  new  Socket();
                     socketAddress =  new  InetSocketAddress(address, ports[port]);
                     try  {
                         socket.connect(socketAddress, timeout);
                         socket.close();
                         SwingUtilities.invokeLater( new  ResultRunnable( ports[port]));   //更新界面                  
                     catch  (IOException e) {
                         
                     }
                     try  {
                         Thread.sleep( 1000 );
                     catch  (InterruptedException e) {
                         e.printStackTrace();
                     }
                 }
             catch  (UnknownHostException e) {
                 e.printStackTrace();
             }
             
         }
         
     }
     class  ScanThread2  implements  Runnable{
         private  String domain;
         private  int  startPort =  20 ,endPort =  100 // 待扫描的端口的Set集合
         private  int  threadNumber, serial, timeout;  // 线程数,这是第几个线程,超时时间
         
         public  ScanThread2(String domain,  int  startPort,  int  endPort,
                 int  threadNumber,  int  serial,  int  timeout) {
             this .domain = domain;
             this .startPort = startPort;
             this .endPort = endPort;
             this .threadNumber = threadNumber;
             this .serial = serial;
             this .timeout = timeout;
         }
 
         public  void  run() {
             int  port =  0 ;
             try  {
                 InetAddress address = InetAddress.getByName(domain);
                 Socket socket;
                 SocketAddress socketAddress;
                 for  (port = startPort + serial; port <= endPort; port += threadNumber) {
                     SwingUtilities.invokeLater( new  ProgressRunnable(port));   //更新界面
                     
                     socket =  new  Socket();
                     socketAddress =  new  InetSocketAddress(address, port);
                     try  {
                         socket.connect(socketAddress, timeout);  // 超时时间
                         socket.close();
                         SwingUtilities.invokeLater( new  ResultRunnable(port));   //更新界面   
                     catch  (IOException e) {
 
                     }
                 }
             catch  (UnknownHostException e) {
                 e.printStackTrace();
             }
             
         }
         
     }
     
     /**
      * 由EDT调用来更新界面的线程
      * */
     class  ProgressRunnable  implements  Runnable{
         private  int  currentPort =  0
         
         public  ProgressRunnable( int  currentPort) {
             this .currentPort = currentPort;
         }
 
         public  void  run() {
             progressJtJTextArea.setEditable( true );
             progressJtJTextArea.append( "正在扫描端口:"  + currentPort +  "\n" );
             progressJtJTextArea.setEditable( false );
             //设置显示最新内容
             progressJtJTextArea.selectAll();
             progressJtJTextArea.setCaretPosition(progressJtJTextArea.getSelectionEnd());
         }
 
     }
     /**
      * 同上
      * */
     class  ResultRunnable  implements  Runnable{
         private  int  currentPort =  0
         
         public  ResultRunnable( int  currentPort) {
             this .currentPort = currentPort;
         }
         public  void  run() {
             resultJTextArea.setEditable( true );
             resultJTextArea.append( "端口:"  + currentPort +  "    开放\n" );
             resultJTextArea.setEditable( false );
             resultJTextArea.selectAll();
             resultJTextArea.setCaretPosition(resultJTextArea.getSelectionEnd());
         }
     }
     
     /**
      * 根据输入的字符串提取出其中的域名字符串或者IP字符串,如:www.zifangsky.cn
     
      * @param str 输入的包含域名的字符串
      * @return 域名或IP字符串
      * */
     public  static  String getDomainString(String str){
         String reg =  "[a-zA-Z0-9][-a-zA-Z0-9]{0,62}(\\.[a-zA-Z0-9][-a-zA-Z0-9]{0,62})+" ;
         Pattern pattern = Pattern.compile(reg);
         Matcher matcher = pattern.matcher(str);
         if (matcher.find()){
             return  matcher.group();
         }
         return  "" ;
     }
     
     public  static  void  main(String[] args){
         SwingUtilities.invokeLater( new  Runnable() {
             public  void  run() {
                 new  PortScan();   
             }
         });
     }
}

三 测试效果

       随便找了一个网站进行测试,效果如下:

wKioL1aQ2KWStPk-AADzIc_EW-k429.png



本文转自 pangfc 51CTO博客,原文链接:http://blog.51cto.com/983836259/1733295,如需转载请自行联系原作者

相关实践学习
基于函数计算快速搭建Hexo博客系统
本场景介绍如何使用阿里云函数计算服务命令行工具快速搭建一个Hexo博客。
相关文章
|
1天前
|
Java
Java中的多线程编程:基础知识与实践
【5月更文挑战第13天】在计算机科学中,多线程是一种使得程序可以同时执行多个任务的技术。在Java语言中,多线程的实现主要依赖于java.lang.Thread类和java.lang.Runnable接口。本文将深入探讨Java中的多线程编程,包括其基本概念、实现方法以及一些常见的问题和解决方案。
|
1天前
|
安全 算法 Java
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第13天】 在Java开发中,并发编程是一个复杂且重要的领域。它不仅关系到程序的线程安全性,也直接影响到系统的性能表现。本文将探讨Java并发编程的核心概念,包括线程同步机制、锁优化技术以及如何平衡线程安全和性能。通过分析具体案例,我们将提供实用的编程技巧和最佳实践,帮助开发者在确保线程安全的同时,提升应用性能。
10 1
|
2天前
|
Java 调度
Java一分钟之线程池:ExecutorService与Future
【5月更文挑战第12天】Java并发编程中,`ExecutorService`和`Future`是关键组件,简化多线程并提供异步执行能力。`ExecutorService`是线程池接口,用于提交任务到线程池,如`ThreadPoolExecutor`和`ScheduledThreadPoolExecutor`。通过`submit()`提交任务并返回`Future`对象,可检查任务状态、获取结果或取消任务。注意处理`ExecutionException`和避免无限等待。实战示例展示了如何异步执行任务并获取结果。理解这些概念对提升并发性能至关重要。
17 5
|
2天前
|
安全 Java 调度
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第12天】 在现代软件开发中,多线程编程是提升应用程序性能和响应能力的关键手段之一。特别是在Java语言中,由于其内置的跨平台线程支持,开发者可以轻松地创建和管理线程。然而,随之而来的并发问题也不容小觑。本文将探讨Java并发编程的核心概念,包括线程安全策略、锁机制以及性能优化技巧。通过实例分析与性能比较,我们旨在为读者提供一套既确保线程安全又兼顾性能的编程指导。
|
3天前
|
Java
Java一分钟:线程协作:wait(), notify(), notifyAll()
【5月更文挑战第11天】本文介绍了Java多线程编程中的`wait()`, `notify()`, `notifyAll()`方法,它们用于线程间通信和同步。这些方法在`synchronized`代码块中使用,控制线程执行和资源访问。文章讨论了常见问题,如死锁、未捕获异常、同步使用错误及通知错误,并提供了生产者-消费者模型的示例代码,强调理解并正确使用这些方法对实现线程协作的重要性。
13 3
|
3天前
|
安全 算法 Java
Java一分钟:线程同步:synchronized关键字
【5月更文挑战第11天】Java中的`synchronized`关键字用于线程同步,防止竞态条件,确保数据一致性。本文介绍了其工作原理、常见问题及避免策略。同步方法和同步代码块是两种使用形式,需注意避免死锁、过度使用导致的性能影响以及理解锁的可重入性和升级降级机制。示例展示了同步方法和代码块的运用,以及如何避免死锁。正确使用`synchronized`是编写多线程安全代码的核心。
55 2
|
3天前
|
安全 Java 调度
Java一分钟:多线程编程初步:Thread类与Runnable接口
【5月更文挑战第11天】本文介绍了Java中创建线程的两种方式:继承Thread类和实现Runnable接口,并讨论了多线程编程中的常见问题,如资源浪费、线程安全、死锁和优先级问题,提出了解决策略。示例展示了线程通信的生产者-消费者模型,强调理解和掌握线程操作对编写高效并发程序的重要性。
43 3
|
3天前
|
安全 Java
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第11天】在Java并发编程中,线程安全和性能优化是两个重要的主题。本文将深入探讨这两个方面,包括线程安全的基本概念,如何实现线程安全,以及如何在保证线程安全的同时进行性能优化。我们将通过实例和代码片段来说明这些概念和技术。
4 0
|
3天前
|
Java 调度
Java并发编程:深入理解线程池
【5月更文挑战第11天】本文将深入探讨Java中的线程池,包括其基本概念、工作原理以及如何使用。我们将通过实例来解释线程池的优点,如提高性能和资源利用率,以及如何避免常见的并发问题。我们还将讨论Java中线程池的实现,包括Executor框架和ThreadPoolExecutor类,并展示如何创建和管理线程池。最后,我们将讨论线程池的一些高级特性,如任务调度、线程优先级和异常处理。
|
4天前
|
安全 Java
【JAVA进阶篇教学】第十篇:Java中线程安全、锁讲解
【JAVA进阶篇教学】第十篇:Java中线程安全、锁讲解