日本搞逼视频_黄色一级片免费在线观看_色99久久_性明星video另类hd_欧美77_综合在线视频

國內(nèi)最全I(xiàn)T社區(qū)平臺 聯(lián)系我們 | 收藏本站
阿里云優(yōu)惠2
您當(dāng)前位置：首頁 > php開源 > php教程 > Java網(wǎng)絡(luò)編程，通過TCP,Socket實現(xiàn)多對一的局域網(wǎng)聊天室

Java網(wǎng)絡(luò)編程，通過TCP,Socket實現(xiàn)多對一的局域網(wǎng)聊天室

來源：程序員人生   發(fā)布時間：2017-02-17 09:47:05 閱讀次數(shù)：3501次

學(xué)習(xí)Java的同學(xué)注意了！！！ 
學(xué)習(xí)進(jìn)程中遇到甚么問題或想獲得學(xué)習(xí)資源的話，歡迎加入Java學(xué)習(xí)交換群，群號碼：183993990  我們1起學(xué)Java！


java網(wǎng)絡(luò)編程，通過TCP,Socket實現(xiàn)多對1的局域網(wǎng)聊天室

可以實現(xiàn)多個客戶端連接服務(wù)器，服務(wù)器接收到信息就會把信息廣播到所有的客戶端

 

這是服務(wù)器真?zhèn)€代碼

復(fù)制代碼
import java.awt.BorderLayout;
import java.awt.FlowLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;
import java.net.Socket;
import java.util.List;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;
/*這個類是服務(wù)器真?zhèn)€UI*/
public class ServerUI extends JFrame {
    public static void main(String[] args) {
        ServerUI serverUI = new ServerUI();
    }

    public JButton btStart;//啟動服務(wù)器
    public JButton btSend;//發(fā)送信息按鈕
    public JTextField tfSend;//需要發(fā)送的文本信息
    public JTextArea taShow;//信息展現(xiàn)
    public Server server;//用來監(jiān)聽客戶端連接
    static List<Socket> clients;//保存連接到服務(wù)器的客戶端

    public ServerUI() {
        super("服務(wù)器端");
        btStart = new JButton("啟動服務(wù)");
        btSend = new JButton("發(fā)送信息");
        tfSend = new JTextField(10);
        taShow = new JTextArea();

        btStart.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                server = new Server(ServerUI.this);
            }
        });
        btSend.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                server.sendMsg(tfSend.getText());
                tfSend.setText("");
            }
        });
        this.addWindowListener(new WindowAdapter() {
            public void windowClosing(WindowEvent e) {
                int a = JOptionPane.showConfirmDialog(null, "肯定關(guān)閉嗎？", "溫馨提示",
                        JOptionPane.YES_NO_OPTION);
                if (a == 1) {
                    server.closeServer();
                    System.exit(0); // 關(guān)閉
                }
            }
        });
        JPanel top = new JPanel(new FlowLayout());
        top.add(tfSend);
        top.add(btSend);
        top.add(btStart);
        this.add(top, BorderLayout.SOUTH);
        final JScrollPane sp = new JScrollPane();
        sp.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
        sp.setViewportView(this.taShow);
        this.taShow.setEditable(false);
        this.add(sp, BorderLayout.CENTER);
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        this.setSize(400, 300);
        this.setLocation(100, 200);
        this.setVisible(true);
    }
}
復(fù)制代碼
復(fù)制代碼
import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;
/*這個類是服務(wù)器真?zhèn)€等待客戶端連接*/
public class Server extends Thread {
    ServerUI ui;
    ServerSocket ss;
    BufferedReader reader;
    PrintWriter writer;

    public Server(ServerUI ui) {
        this.ui = ui;
        this.start();
    }

    public void run() {
        try {

            ss = new ServerSocket(1228);
            ui.clients=new ArrayList<Socket>();
            println("啟動服務(wù)器成功：端口1228");
            
            while (true) {
                println("等待客戶端");
                Socket client = ss.accept();
                ui.clients.add(client);
                println("連接成功" + client.toString());
                new ListenerClient(ui, client);
            }
        } catch (IOException e) {
            println("啟動服務(wù)器失敗：端口1228");
            println(e.toString());
            e.printStackTrace();
        }

    }

    public synchronized void sendMsg(String msg) {
        try {
            for (int i = 0; i < ui.clients.size(); i++) {
                Socket client = ui.clients.get(i);
                writer = new PrintWriter(client.getOutputStream(), true);
                writer.println(msg);
            }

        } catch (Exception e) {
            println(e.toString());
        }
    }

    public void println(String s) {
        if (s != null) {
            this.ui.taShow.setText(this.ui.taShow.getText() + s + "\n");
            System.out.println(s + "\n");
        }
    }

    public void closeServer() {
        try {
            if (ss != null)
                ss.close();
            if (reader != null)
                reader.close();
            if (writer != null)
                writer.close();
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

    }
}
復(fù)制代碼
復(fù)制代碼
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
/*這個類是服務(wù)器真?zhèn)€等待客戶端發(fā)送信息*/
public class ListenerClient extends Thread {
    BufferedReader reader;
    PrintWriter writer;
    ServerUI ui;
    Socket client;
    public ListenerClient(ServerUI ui, Socket client) {
        this.ui = ui;
        this.client=client;
        this.start();
    }
    //為每個客戶端創(chuàng)建線程等待接收信息，然后把信息廣播出去
    public void run() {
        String msg = "";
        while (true) {
            try {
                reader = new BufferedReader(new InputStreamReader(
                        client.getInputStream()));
                writer = new PrintWriter(client.getOutputStream(), true);
                msg = reader.readLine();
                sendMsg(msg);
                
            } catch (IOException e) {
                println(e.toString());
                // e.printStackTrace();
                break;
            }
            if (msg != null && msg.trim() != "") {
                println(">>" + msg);
            }
        }
    }
    //把信息廣播到所有用戶
    public synchronized void sendMsg(String msg) {
        try {
            for (int i = 0; i < ui.clients.size(); i++) {
                Socket client = ui.clients.get(i);
                writer = new PrintWriter(client.getOutputStream(), true);
                writer.println(msg);
            }

        } catch (Exception e) {
            println(e.toString());
        }
    }

    

    public void println(String s) {
        if (s != null) {
            this.ui.taShow.setText(this.ui.taShow.getText() + s + "\n");
            System.out.println(s + "\n");
        }
    }
}
復(fù)制代碼

 

客戶端代碼

復(fù)制代碼
import java.awt.BorderLayout;
import java.awt.FlowLayout;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.awt.event.WindowAdapter;
import java.awt.event.WindowEvent;

import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JOptionPane;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;

public class ClientUI extends JFrame {
    public static void main(String[] args) {
        ClientUI client = new ClientUI();
    }
    public ClientUI() {
        super("客戶端");
        btStart = new JButton("啟動連接");
        btSend = new JButton("發(fā)送信息");
        tfSend = new JTextField(10);
        tfIP = new JTextField(10);
        tfPost = new JTextField(5);
        taShow = new JTextArea();

        btStart.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                server = new ClientThread(ClientUI.this);
            }
        });
        btSend.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                server.sendMsg(tfSend.getText());
                tfSend.setText("");
            }
        });
        this.addWindowListener(new WindowAdapter() {
            public void windowClosing(WindowEvent e) {
                int a = JOptionPane.showConfirmDialog(null, "肯定關(guān)閉嗎？", "溫馨提示",
                        JOptionPane.YES_NO_OPTION);
                if (a == 1) {
                    System.exit(0); // 關(guān)閉
                }
            }
        });
        JPanel top = new JPanel(new FlowLayout());
        top.add(tfSend);
        top.add(btSend);
        top.add(btStart);
        this.add(top, BorderLayout.SOUTH);
        final JScrollPane sp = new JScrollPane();
        sp.setVerticalScrollBarPolicy(JScrollPane.VERTICAL_SCROLLBAR_ALWAYS);
        sp.setViewportView(this.taShow);
        this.taShow.setEditable(false);
        this.add(sp, BorderLayout.CENTER);
        this.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        this.setSize(400, 300);
        this.setLocation(600, 200);
        this.setVisible(true);
    }

    public     JButton btStart;
    public     JButton btSend;
    public     JTextField tfSend;
    public     JTextField tfIP;
    public     JTextField tfPost;
    
    public     JTextArea taShow;
    public     ClientThread server;
    

}
復(fù)制代碼
復(fù)制代碼
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ClientThread extends Thread {
    ClientUI ui;
    Socket client;
    BufferedReader reader;
    PrintWriter writer;

    public ClientThread(ClientUI ui) {
        this.ui = ui;
        try {
            client = new Socket("127.0.0.1", 1228);//這里設(shè)置連接服務(wù)器真?zhèn)€IP的端口
            println("連接服務(wù)器成功：端口1228");
            reader = new BufferedReader(new InputStreamReader(
                    client.getInputStream()));
            writer = new PrintWriter(client.getOutputStream(), true);
            // 如果為 true，則 println、printf 或 format 方法將刷新輸出緩沖區(qū)
        } catch (IOException e) {
            println("連接服務(wù)器失敗：端口1228");
            println(e.toString());
            e.printStackTrace();
        }
        this.start();
    }

    public void run() {
        String msg = "";
        while (true) {
            try {
                msg = reader.readLine();
            } catch (IOException e) {
                println("服務(wù)器斷開連接");

                break;
            }
            if (msg != null && msg.trim() != "") {
                println(">>" + msg);
            }
        }
    }

    public void sendMsg(String msg) {
        try {
            writer.println(msg);
        } catch (Exception e) {
            println(e.toString());
        }
    }

    public void println(String s) {
        if (s != null) {
            this.ui.taShow.setText(this.ui.taShow.getText() + s + "\n");
            System.out.println(s + "\n");
        }
    }
    
}
復(fù)制代碼

學(xué)習(xí)Java的同學(xué)注意了！！！ 
學(xué)習(xí)進(jìn)程中遇到甚么問題或想獲得學(xué)習(xí)資源的話，歡迎加入Java學(xué)習(xí)交換群，群號碼：183993990  我們1起學(xué)Java！

生活不易，碼農(nóng)辛苦
如果您覺得本網(wǎng)站對您的學(xué)習(xí)有所幫助,可以手機(jī)掃描二維碼進(jìn)行捐贈
程序員人生
------分隔線----------------------------
分享到:
------分隔線----------------------------
汐顏
積分：3341
6粉絲
0關(guān)注
欄目熱點
關(guān)閉
程序員人生
主站蜘蛛池模板： 亚洲免费黄色 | 精品少妇一区二区三区免费观看 | 久久久国产精品一区二区三区 | 丁香午夜 | 精品美女久久久久久免费 | 国产视频亚洲 | 中文字幕一级 | 神马久久久久久 | 欧美乱性| 国产精品不卡一区二区三区 | 免费国产福利 | 日本成人在线播放 | 欧美日韩一区三区 | 91香蕉视频导航 | 91先生在线 | 亚洲精品美女久久久 | 精品91久久 | 欧美日韩亚洲综合 | 99re这里只有精品在线视频 | 国产精品久久久久久久久免费 | 亚洲欧美一区二区三区四区 | 欧美精品网 | 国产综合精品一区二区三区 | 日韩专区一区二区 | 欧美一区二区不卡视频 | 国产不卡在线视频 | 久久久久久国产精品免费免费狐狸 | 精品欧美| 国产在线精品福利 | 久久久久久国产 | 日韩精品中文字幕一区二区三区 | 久久久a | 欧美激情综合五月色丁香小说 | 精品久草 | 午夜av成人| 91一级| 欧美二区视频 | 黄网站免费在线观看 | 国产一区二区视频在线播放 | 久久久久久久久久久网站 | 欧美电影一区 |