TCP一對一聊天

客戶端

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.Font;
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 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 ClientSocketFrame extends JFrame {private PrintWriter writer; // 聲明PrintWriter類對象private BufferedReader reader; // 聲明BufferedReader對象private Socket socket; // 聲明Socket對象private JTextArea ta_info; // 創建JtextArea對象private JTextField tf_send; // 創建JtextField對象private void connect() { // 連接套接字方法ta_info.append("嘗試連接......\n"); // 文本域中信息信息try { // 捕捉異常socket = new Socket("127.0.0.1", 1978); // 實例化Socket對象while (true) {writer = new PrintWriter(socket.getOutputStream(), true);reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 實例化BufferedReader對象ta_info.append("完成連接。\n"); // 文本域中提示信息getServerInfo();}} catch (Exception e) {e.printStackTrace(); // 輸出異常信息}}public static void main(String[] args) { // 主方法ClientSocketFrame clien = new ClientSocketFrame(); // 創建本例對象clien.setVisible(true); // 將窗體顯示clien.connect(); // 調用連接方法}private void getServerInfo() {try {while (true) {if (reader != null) {String line = reader.readLine();// 讀取服務器發送的信息if (line != null)ta_info.append("接收到服務器發送的信息：" + line + "\n"); // 顯示服務器端發送的信息}}} catch (Exception e) {e.printStackTrace();} finally {try {if (reader != null) {reader.close();// 關閉流}if (socket != null) {socket.close(); // 關閉套接字}} catch (IOException e) {e.printStackTrace();}}}/*** Create the frame*/public ClientSocketFrame() {super();setTitle("客戶端程序");setBounds(100, 100, 361, 257);setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);final JPanel panel = new JPanel();getContentPane().add(panel, BorderLayout.NORTH);final JLabel label = new JLabel();label.setForeground(new Color(0, 0, 255));label.setFont(new Font("", Font.BOLD, 22));label.setText("一對一通信——客戶端程序");panel.add(label);final JPanel panel_1 = new JPanel();getContentPane().add(panel_1, BorderLayout.SOUTH);final JLabel label_1 = new JLabel();label_1.setText("客戶端發送的信息：");panel_1.add(label_1);tf_send = new JTextField();tf_send.setPreferredSize(new Dimension(140, 25));panel_1.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {writer.println(tf_send.getText()); // 將文本框中信息寫入流ta_info.append("客戶端發送的信息是：" + tf_send.getText()+ "\n"); // 將文本框中信息顯示在文本域中tf_send.setText(""); // 將文本框清空}});button.setText("發  送");panel_1.add(button);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);//}}

服務端?

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.Dimension;
import java.awt.Font;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.io.*;
import java.net.*;
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 ServerSocketFrame extends JFrame {private JTextField tf_send;private JTextArea ta_info;private PrintWriter writer; // 聲明PrintWriter類對象private BufferedReader reader; // 聲明BufferedReader對象private ServerSocket server; // 聲明ServerSocket對象private Socket socket; // 聲明Socket對象socketpublic void getServer() {try {server = new ServerSocket(1978); // 實例化Socket對象ta_info.append("服務器套接字已經創建成功\n"); // 輸出信息while (true) { // 如果套接字是連接狀態ta_info.append("等待客戶機的連接......\n"); // 輸出信息socket = server.accept(); // 實例化Socket對象reader = new BufferedReader(new InputStreamReader(socket.getInputStream())); // 實例化BufferedReader對象writer = new PrintWriter(socket.getOutputStream(), true);getClientInfo(); // 調用getClientInfo()方法}} catch (Exception e) {e.printStackTrace(); // 輸出異常信息}}private void getClientInfo() {try {while (true) {String line = reader.readLine();// 讀取客戶端發送的信息if (line != null)ta_info.append("接收到客戶機發送的信息：" + line + "\n"); // 顯示客戶端發送的信息}} catch (Exception e) {ta_info.append("客戶端已退出。\n"); // 輸出異常信息} finally {try {if (reader != null) {reader.close();// 關閉流}if (socket != null) {socket.close(); // 關閉套接字}} catch (IOException e) {e.printStackTrace();}}}public static void main(String[] args) { // 主方法ServerSocketFrame frame = new ServerSocketFrame(); // 創建本類對象frame.setVisible(true);frame.getServer(); // 調用方法}public ServerSocketFrame() {super();setTitle("服務器端程序");setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);setBounds(100, 100, 379, 260);final JScrollPane scrollPane = new JScrollPane();getContentPane().add(scrollPane, BorderLayout.CENTER);ta_info = new JTextArea();scrollPane.setViewportView(ta_info);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.setPreferredSize(new Dimension(150, 25));panel.add(tf_send);final JButton button = new JButton();button.addActionListener(new ActionListener() {public void actionPerformed(final ActionEvent e) {writer.println(tf_send.getText()); // 將文本框中信息寫入流ta_info.append("服務器發送的信息是：" + tf_send.getText() + "\n"); // 將文本框中信息顯示在文本域中tf_send.setText(""); // 將文本框清空}});button.setText("發  送");panel.add(button);final JPanel panel_1 = new JPanel();getContentPane().add(panel_1, BorderLayout.NORTH);final JLabel label_1 = new JLabel();label_1.setForeground(new Color(0, 0, 255));label_1.setFont(new Font("", Font.BOLD, 22));label_1.setText("一對一通信——服務器端程序");panel_1.add(label_1);}
}

結果展示

?第二種

客戶端

 import java.io.*;
import java.net.Socket;
import java.util.Scanner;/*** Socket客戶端**/
public class SocketClient {public static void main(String[] args) {Socket s = null;try {// 與ip為127.0.0.1、端口為12345的服務端建立連接s = new Socket("127.0.0.1", 12345);// 創建輸入流接收服務端發送的消息（字節流）InputStream is = s.getInputStream();// 將服務端返回的字節流轉化為字符流InputStreamReader isr = new InputStreamReader(is);// 創建字符流讀取緩沖區，方便每行讀取BufferedReader br = new BufferedReader(isr);// 創建輸出流返回消息OutputStream os = s.getOutputStream();// 創建輸出流緩沖PrintWriter pw = new PrintWriter(os);// 創建發送消息的線程Runnable rOut = () -> {boolean flag = true;while (flag) {try {// 接收控制臺輸入Scanner scan = new Scanner(System.in);String msg = scan.nextLine();// 將輸入寫入緩沖pw.println(msg);// 將緩沖內的數據推送至服務端并清空緩沖區pw.flush();} catch (Exception e) {flag = false;e.printStackTrace();}}};// 創建接收消息的線程Runnable rIn = () -> {boolean flag = true;while (flag) {try {// 逐行讀取服務端返回的消息并打印String str = br.readLine();System.out.println("服務端的消息：" + str);} catch (IOException e) {flag = false;e.printStackTrace();}}};// 啟動兩個線程Thread tOut = new Thread(rOut);Thread tIn = new Thread(rIn);tOut.start();tIn.start();}catch (IOException e) {try {// 釋放資源s.close();} catch (Exception exception) {exception.printStackTrace();}e.printStackTrace();}}
}

服務端

 
import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.Scanner;/*** Socket服務端**/
public class SocketServer {public static void main(String[] args) {ServerSocket ss = null;Socket s = null;try {// 創建監聽端口為12345的Socket服務端ss = new ServerSocket(12345);System.out.println("服務端Socket服務已建立，等待客戶端連接...");// 通過ss.accept()開始持續監聽12345端口，當有連接時獲取收到的包裝成Socket的客戶端對象s = ss.accept();// 獲取客戶端的IP地址和端口號String ip = s.getInetAddress().getHostAddress();int port = s.getPort();System.out.println("服務端與 " + ip + ":" + port + " 已建立連接");// 創建輸入流接收客戶端發送的消息（字節流）InputStream is = s.getInputStream();// 將客戶端發送的字節流轉化為字符流InputStreamReader isr = new InputStreamReader(is);// 創建字符流讀取緩沖區，方便每行讀取BufferedReader br = new BufferedReader(isr);// 創建輸出流返回消息OutputStream os = s.getOutputStream();// 創建輸出流緩沖PrintWriter pw = new PrintWriter(os);// 創建接受信息的線程Runnable rIn = () -> {boolean flag = true;while (flag) {try {// 逐行讀取客戶端發送的消息并打印String str = br.readLine();System.out.println("客戶端的消息：" + str);} catch (IOException e) {flag = false;e.printStackTrace();}}};// 創建發送消息的線程Runnable rOut = () -> {boolean flag = true;while (flag) {try {// 接收控制臺輸入Scanner scan = new Scanner(System.in);String msg = scan.nextLine();// 將輸入寫入緩沖pw.println(msg);// 將緩沖內的數據推送至客戶端并清空緩沖區pw.flush();} catch (Exception e) {flag = false;e.printStackTrace();}}};// 開啟兩個線程Thread tIn = new Thread(rIn);Thread tOut = new Thread(rOut);tIn.start();tOut.start();} catch (IOException e) {try {// 釋放資源ss.close();s.close();} catch (Exception exception) {exception.printStackTrace();}e.printStackTrace();}}
}

結果