Ver código fonte

Update Server.java

1901010113 4 anos atrás
pai
commit
9d5b1b97b4
2 arquivos alterados com 31 adições e 32 exclusões
  1. 1 0
      src/main/java/bean/Info.java
  2. 30 32
      src/main/java/starter/Server.java

+ 1 - 0
src/main/java/bean/Info.java

@@ -10,6 +10,7 @@ import java.util.List;
 
 /**
  * 服务器和客户端之间的消息协议
+ * type:
  * 0-C/S第一次握手信息
  * 1-client请求广播信息
  * 2-保留

+ 30 - 32
src/main/java/starter/Server.java

@@ -32,7 +32,7 @@ public class Server extends JFrame {
     /**
      * 服务器端口
      */
-    private static final int PORT = 8080;
+    private static int PORT = 8080;
     /**
      * 保存在线用户信息,用户名-文本输出流
      */
@@ -110,36 +110,6 @@ public class Server extends JFrame {
         clear_btn.setBounds(234, 50, 97, 23);
         contentPane.add(clear_btn);
 
-
-
-        /**
-         * 关闭服务器点击事件
-         */
-        close_btn.addActionListener(new ActionListener() {
-            @Override
-            public void actionPerformed(ActionEvent e) {
-                // TODO: 2020/6/26
-                try {
-                    if (! serverSocket.isClosed()) {
-                        //仅可以在连接前关闭
-                        serverSocket.close();
-                        textArea.append(ToolUtils.getRealTime() + ",服务器关闭成功\n");  }
-                }catch (IOException ex) {
-                    ex.printStackTrace();
-                }
-            }
-        });
-
-        /**
-         * 清空聊天框点击事件
-         */
-        clear_btn.addActionListener(new ActionListener() {
-            @Override
-            public void actionPerformed(ActionEvent e) {
-                textArea.setText(" ");
-            }
-        });
-
         /**
          * 开启服务器点击事件
          */
@@ -149,7 +119,7 @@ public class Server extends JFrame {
                 new Thread(new Runnable() {
                     @Override
                     public void run() {
-                        int PORT = Integer.parseInt(port_edit.getText());
+                        PORT = Integer.parseInt(port_edit.getText());
                         try {
                             serverSocket = new ServerSocket(PORT);
                             serverSocket.setSoTimeout(5*10000);
@@ -170,6 +140,34 @@ public class Server extends JFrame {
             }
         });
 
+        /**
+         * 关闭服务器点击事件
+         */
+        close_btn.addActionListener(new ActionListener() {
+            @Override
+            public void actionPerformed(ActionEvent e) {
+                // TODO: 2020/6/26
+                try {
+                    if (! serverSocket.isClosed()) {
+                        //仅可以在连接前关闭
+                        serverSocket.close();
+                        textArea.append(ToolUtils.getRealTime() + ",服务器关闭成功\n");  }
+                }catch (IOException ex) {
+                    ex.printStackTrace();
+                }
+            }
+        });
+
+        /**
+         * 清空聊天框点击事件
+         */
+        clear_btn.addActionListener(new ActionListener() {
+            @Override
+            public void actionPerformed(ActionEvent e) {
+                textArea.setText(" ");
+            }
+        });
+
     }
 
     public static void main(String[] args) {