服務端?

package 一對一用戶;import java.awt.BorderLayout;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Vector;
import javax.swing.JFrame;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;public class fuwuchuangkou extends JFrame {private JTextArea ta_info;private ServerSocket server; // 聲明ServerSocket對象private Socket socket; // 聲明Socket對象socketprivate Vector<Socket> vector = new Vector<Socket>();// 用于存儲連接到服務器的客戶端套接字對象public void createSocket() {try {server = new ServerSocket(1978);while (true) {ta_info.append("等待新客戶連接......\n");socket = server.accept();// 創建套接字對象vector.add(socket);// 將套接字對象添加到向量對象中ta_info.append("客戶端連接成功。" + socket + "\n");new ServerThread(socket).start();// 創建并啟動線程對象}} catch (IOException e) {e.printStackTrace();}}class ServerThread extends Thread {Socket socket;public ServerThread(Socket socket) {this.socket = socket;}public void run() {try {BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 創建輸入流對象while (true) {String info = in.readLine();// 讀取信息for (Socket s : vector) {// 遍歷所有客戶端套接字對象if (s != socket) {// 如果不是發送信息的套接字對象PrintWriter out = new PrintWriter(s.getOutputStream(), true);// 創建輸出流對象out.println(info);// 發送信息out.flush();// 刷新輸出緩沖區}}}} catch (IOException e) {ta_info.append(socket + "已經退出。\n");vector.remove(socket);// 移除退出的客戶端套接字}}}public static void main(String args[]) {fuwuchuangkou frame = new fuwuchuangkou();frame.setVisible(true);frame.createSocket();}/*** Create the frame*/public fuwuchuangkou() {super();setTitle("一對一");setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);}
}

?客戶端

package 一對一用戶;import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;public class kehuchuangkou extends JFrame {private JTextArea ta_info;private JTextField tf_send;PrintWriter out;// 聲明輸出流對象/*** Launch the application* * @param args*/public static void main(String args[]) {EventQueue.invokeLater(new Runnable() {public void run() {try {kehuchuangkou frame = new kehuchuangkou();frame.setVisible(true);frame.createClientSocket();} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try {Socket socket = new Socket("127.0.0.1", 1978);// 連接本地1978端口out = new PrintWriter(socket.getOutputStream(), true);// 創建輸出流對象new ClientThread(socket).start();// 創建并啟動線程對象} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}class ClientThread extends Thread {Socket socket;public ClientThread(Socket socket) {this.socket = socket;}public void run() {try {BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 創建輸入流對象while (true) {String info = in.readLine();// 讀取信息ta_info.append(info + "\n");// 在文本域中顯示信息if (info.equals("88")) {break;// 結束線程}}} catch (IOException e) {e.printStackTrace();}}}private void send() {String info = tf_send.getText();// 獲得輸入的信息if (info.equals("")) {return;// 如果沒輸入信息則返回，即不發送}if (info.equals("88")) {System.exit(0);// 如果沒輸入信息是88，則退出}out.println(info);// 發送信息out.flush();// 刷新輸出緩沖區tf_send.setText(null);// 清空文本框}public kehuchuangkou() {  //創建面板super();setTitle("一對一");setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JPanel panel = new JPanel();getContentPane().add(panel, BorderLayout.SOUTH);final JLabel label = new JLabel();label.setText("輸入聊天內容：");panel.add(label);tf_send = new JTextField();tf_send.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});tf_send.setPreferredSize(new Dimension(180, 25));panel.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});button.setText("發  送");panel.add(button);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);}}

package 一對一用戶;import java.awt.BorderLayout;
import java.awt.Dimension;
import java.awt.EventQueue;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;
import javax.swing.JButton;
import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JPanel;
import javax.swing.JScrollPane;
import javax.swing.JTextArea;
import javax.swing.JTextField;public class kehu1 extends JFrame {private JTextArea ta_info;private JTextField tf_send;PrintWriter out;// 聲明輸出流對象/*** Launch the application* * @param args*/public static void main(String args[]) {EventQueue.invokeLater(new Runnable() {public void run() {try {kehuchuangkou frame = new kehuchuangkou();frame.setVisible(true);frame.createClientSocket();} catch (Exception e) {e.printStackTrace();}}});}public void createClientSocket() {try {Socket socket = new Socket("127.0.0.1", 1978);// 連接本地1978端口out = new PrintWriter(socket.getOutputStream(), true);// 創建輸出流對象new ClientThread(socket).start();// 創建并啟動線程對象} catch (UnknownHostException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}}class ClientThread extends Thread {Socket socket;public ClientThread(Socket socket) {this.socket = socket;}public void run() {try {BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));// 創建輸入流對象while (true) {String info = in.readLine();// 讀取信息ta_info.append(info + "\n");// 在文本域中顯示信息if (info.equals("88")) {break;// 結束線程}}} catch (IOException e) {e.printStackTrace();}}}private void send() {String info = tf_send.getText();// 獲得輸入的信息if (info.equals("")) {return;// 如果沒輸入信息則返回，即不發送}if (info.equals("88")) {System.exit(0);// 如果沒輸入信息是88，則退出}out.println(info);// 發送信息out.flush();// 刷新輸出緩沖區tf_send.setText(null);// 清空文本框}public kehu1() {  //創建面板super();setTitle("一對一");setBounds(100, 100, 385, 266);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JPanel panel = new JPanel();getContentPane().add(panel, BorderLayout.SOUTH);final JLabel label = new JLabel();label.setText("輸入聊天內容：");panel.add(label);tf_send = new JTextField();tf_send.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});tf_send.setPreferredSize(new Dimension(180, 25));panel.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {send();}});button.setText("發  送");panel.add(button);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);}}

實現：

?