Java中使用Socket實現服務器端和客戶端通訊

創建服務器端serverSocket

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

/**
 * 服務端
 * @author Administrator
 *
 */
public class Server {

    public static void main(String[] args) throws IOException {
        //創建一個服務器端socket，指定綁定的端口號，並監聽此端口
        ServerSocket serverSocket = new ServerSocket(8888);
        //調用accept()方法開始監聽，等待客戶端的連接
        System.out.println("**********服務器即將啟動，等待客戶端的連接*************");
        Socket socket = serverSocket.accept();
        //獲取輸入流，並讀取客戶端信息
        InputStream inp = socket.getInputStream();
        //把字節流轉換成字符流
        InputStreamReader isr = new InputStreamReader(inp);
        //為字符流增加緩沖區
        BufferedReader bfr = new BufferedReader(isr);
        String info = null;
        while((info=bfr.readLine())!=null){//循環讀取數據
            System.out.println("我是服務器，客戶端說："+info);
        }
        socket.shutdownInput();//關閉輸入流
        //向客戶端傳遞的信息
        OutputStream ots = socket.getOutputStream();
        PrintWriter pw = new PrintWriter(ots);
        pw.write("歡迎登陸");
        pw.flush();
        
        //關閉資源
        pw.close();
        ots.close();
        bfr.close();
        isr.close();
        inp.close();
        socket.close();
        serverSocket.close();
        
    }
    
}

創建客戶端socket

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.UnknownHostException;

/**
 * 客戶端
 * @author Administrator
 *
 */
public class Client {

    public static void main(String[] args) {
        try {
            //創建一個客戶端socket
            Socket socket = new Socket("localhost",8888);
            //向服務器端傳遞信息
            OutputStream ots = socket.getOutputStream();
            PrintWriter pw = new PrintWriter(ots);
            pw.write("用戶名：admin;密碼：123");
            pw.flush();
            //關閉輸出流
            socket.shutdownOutput();
            //獲取服務器端傳遞的數據
            InputStream is = socket.getInputStream();
            InputStreamReader isr = new InputStreamReader(is);
            BufferedReader br = new BufferedReader(isr);
            String info = null;
            while((info=br.readLine())!=null){
                System.out.println("我是客戶端，服務器說："+info);
            }
            //關閉資源
            br.close();
            isr.close();
            is.close();
            pw.close();
            ots.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
    
}

先啟動服務器端，再啟動客戶端

服務器端打印結果為

**********服務器即將啟動，等待客戶端的連接*************
我是服務器，客戶端說：用戶名：admin;密碼：123

客戶端打印結果

我是客戶端，服務器說：歡迎登陸