小修小改

Author: gaopu

CrawlPandaDanmu/.idea/workspace.xml

@@ -7,7 +7,6 @@
 import java.io.IOException;
 import java.io.OutputStream;
 import java.net.Socket;
-import java.util.Arrays;
 import java.util.List;
 
 /**
@@ -37,6 +36,7 @@ public class Crawl extends Thread {
      * @throws IOException
      */
     public boolean init() throws IOException {
+        System.out.println("获取登录信息");
         String roomId = Utils.getRoomId();
         String time = String.valueOf(System.currentTimeMillis());
 
@@ -103,7 +103,7 @@ public boolean init() throws IOException {
      */
     public void login() throws IOException {
         socket = new Socket(serverIp,port);
-        System.out.println("连接弹幕服务器:" + serverIp + ":" + port);
+        System.out.println("登录弹幕服务器:" + serverIp + ":" + port);
         ByteArrayOutputStream byteArray = new ByteArrayOutputStream();
         byte[] b = new byte[]{0x00, 0x06, 0x00, 0x02, 0x00, 0x61};
         byteArray.write(b);
@@ -124,12 +124,16 @@ public void login() throws IOException {
 
     @Override
     public void run() {
-        MessageHandler messageHandler;
+        MessageHandler messageHandler = null;
         OutputStream outputStream;
 
         try {
-            init();
+            //初始化失败
+            if (!init()) {
+                return;
+            }
             login();
+            System.out.println("----------------------------");
 
             messageHandler = new MessageHandler(socket);
             outputStream = socket.getOutputStream();
@@ -160,6 +164,12 @@ public void run() {
             e.printStackTrace();
         } catch (InterruptedException e) {
             e.printStackTrace();
+        } finally {
+            try {
+                messageHandler.close();
+            } catch (IOException e) {
+                e.printStackTrace();
+            }
         }
     }
 }

CrawlPandaDanmu/src/main/java/Crawl.java

@@ -1,2 +1,2 @@
-#要抓取的斗鱼房间网址
-roomId = 88911
+#要抓取的熊猫房间ID
+roomId = 224588