1. 程式人生 > >Java Socket編程之TCP

Java Socket編程之TCP

null 即將 import tip rate 客戶端信息 連接建立 adl exce

基於TCP的Socket通信:

服務器端:

  1. 創建一個服務器端Socket,即ServerSocket,指定綁定的端口,並監聽此端口
  2. 調用accept()方法開始監聽,等待客戶端的連接
  3. 連接建立後,通過輸入流讀取客戶發送的請求信息
  4. 通過輸出流向客戶端發送響應信息
  5. 關閉相關資源

客戶端:

  1. 創建客戶端Socket,指定服務器地址和端口
  2. 連接建立後,通過輸出流,向服務器端發送信息
  3. 獲取輸入流,並讀取服務器端的響應信息
  4. 關閉資源

例:服務器端:

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.InetAddress; import java.net.ServerSocket; import java.net.Socket; public class Server { public static void main(String[] args) { try { //1.創建一個服務器端Socket,即ServerSocket,指定綁定的端口,並監聽此端口
ServerSocket serverSocket=new ServerSocket(8888); Socket socket=null; //記錄客戶端的數量 int count=0; System.out.println("***服務器即將啟動,等待客戶端的連接***"); //循環監聽等待客戶端的連接 while(true){ //調用accept()方法開始監聽,等待客戶端的連接 socket=serverSocket.accept();
//創建一個新的線程 ServerThread serverThread=new ServerThread(socket); //啟動線程 serverThread.start(); count++;//統計客戶端的數量 System.out.println("客戶端的數量:"+count); InetAddress address=socket.getInetAddress(); System.out.println("當前客戶端的IP:"+address.getHostAddress()); } } catch (IOException e) { e.printStackTrace(); } } }

客戶端:

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;

public class Client {
    public static void main(String[] args) {
        try {
            //1.創建客戶端Socket,指定服務器地址和端口
            Socket socket=new Socket("localhost", 8888);
            //2.獲取輸出流,向服務器端發送信息
            OutputStream os=socket.getOutputStream();//字節輸出流
            PrintWriter pw=new PrintWriter(os);//將輸出流包裝為打印流
            pw.write("用戶名:alice;密碼:789");
            pw.flush();
            socket.shutdownOutput();//關閉輸出流
            //3.獲取輸入流,並讀取服務器端的響應信息
            InputStream is=socket.getInputStream();
            BufferedReader br=new BufferedReader(new InputStreamReader(is));
            String info=null;
            while((info=br.readLine())!=null){
                System.out.println("我是客戶端,服務器說:"+info);
            }
            //4.關閉資源
            br.close();
            is.close();
            pw.close();
            os.close();
            socket.close();
        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

服務器線程處理類:

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;

public class ServerThread extends Thread {
    // 和本線程相關的Socket
    Socket socket = null;
        public ServerThread(Socket socket) {
        this.socket = socket;
    }
    //線程執行的操作,響應客戶端的請求
    public void run(){
        InputStream is=null;
        InputStreamReader isr=null;
        BufferedReader br=null;
        OutputStream os=null;
        PrintWriter pw=null;
        try {
            //獲取輸入流,並讀取客戶端信息
            is = socket.getInputStream();
            isr = new InputStreamReader(is);
            br = new BufferedReader(isr);
            String info=null;
            while((info=br.readLine())!=null){//循環讀取客戶端的信息
                System.out.println("我是服務器,客戶端說:"+info);
            }
            socket.shutdownInput();//關閉輸入流
            //獲取輸出流,響應客戶端的請求
            os = socket.getOutputStream();
            pw = new PrintWriter(os);
            pw.write("歡迎您!");
            pw.flush();//調用flush()方法將緩沖輸出
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }finally{
            //關閉資源
            try {
                if(pw!=null)
                    pw.close();
                if(os!=null)
                    os.close();
                if(br!=null)
                    br.close();
                if(isr!=null)
                    isr.close();
                if(is!=null)
                    is.close();
                if(socket!=null)
                    socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

使用TCP通信傳輸對象:

ObjectOutputStream oos=new ObjectOutputStream(os);

User user=new User(“admin”,”123”);//封裝為對象

oos.writeObject(user);//序列化

Tips:

  優先級問題:serverthread.setPriority();//降低優先級,以防運行速度較慢

輸入輸出流問題:同一個Socket,關閉輸出流則會關閉與之關聯的Socket,所以不用關閉輸出流,最後關閉Socket即可。

Java Socket編程之TCP