(个人娱乐)带界面的多线程实例.docVIP

服务器： public class Server extends JFrame { private JPanel contentPane; private JTextArea textArea; private ServerSocket serverSocket; private int port = 54321; /** * Launch the application. */ public static void main(String[] args) { EventQueue.invokeLater(new Runnable() { public void run() { try { Server frame = new Server(); frame.setVisible(true); } catch (Exception e) { e.printStackTrace(); } } }); } /** * Create the frame. */ public Server() { setTitle(\u670D\u52A1\u5668); setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE); setBounds(100, 100, 450, 300); contentPane = new JPanel(); contentPane.setBorder(new EmptyBorder(5, 5, 5, 5)); setContentPane(contentPane); contentPane.setLayout(null); textArea = new JTextArea(); textArea.setEditable(false); textArea.setBounds(10, 10, 414, 242); contentPane.add(textArea); Runsocket r = new Runsocket(); new Thread(r).start(); } public void GetSocket() { try { serverSocket = new ServerSocket(port); while(true) { System.out.println(recieving......); Socket s = serverSocket.accept(); System.out.println(come one client!); //为新到来的socket建立新线程 Sockets sockets = new Sockets(s); new Thread(sockets).start(); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } } public class Sockets implements Runnable { Socket socket; BufferedReader in; Sockets(Socket socket) { this.socket = socket; } public void run() { try { in = new BufferedReader(new InputStreamReader(socket.getInputStream())); while(true){ String message = in.readLine(); if(message.equals($)){break;} //收到$后断开此连接 System.out.println(received:+message); textArea.append(message); textArea.append(\n); } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); System.out.println(error ); } finally { tr