java中實現tcp的發送和接收數據

Tcp協議是面向連接的，可靠的的協議，Tcp是通過三次握手建立連接，Tcp的發送和接收都是端對端的發送和接收。

一、發送端的編程思路

　　1、創建一個發送端的socket；

　　2、獲取到輸出流；

　　3、將需要寫入的數據寫在控制台。

二、接收端的編程思路

　　1、創建一個接收端的ServerSocket；

　　2、 偵聽並接受到此套接字的連接，返回一個Socket對象；

　　3、獲取到輸入流；

　　4、將獲取到的數據打印在控制台上。

三、代碼如下

　　

package net;

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

public class TcpSendAndRecv {
    public static void main(String[] args) {
    new Thread(new DD()).start();
//先開啟接收端的線程
    new Thread(new TT()).start();
//在開啟發送端的線程
}
}
//發送端的代碼如下：
class TT implements Runnable{

    @Override
    public void run() {
    try {
        Socket s=  new Socket("localhost",9977);
//創建一個socket綁定的端口和地址為：9977，本機。
        OutputStream oos = s.getOutputStream();
//獲取到輸出流
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(oos));
        BufferedReader br = new BufferedReader(new InputStreamReader(System.in));
        String line= null;
        while((line=br.readLine())!=null){
            bw.write(line);
            bw.flush();
//將內容寫到控制台
        }
    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }
    
        
    }

}
//接收端的代碼
class DD implements Runnable{

    @Override
    public void run() {
        try { 
　　　　　　　ServerSocket ss  = new ServerSocket(9977);
//創建一個serversocket其端口與發送端的端口是一樣的
            Socket s = ss.accept();
//偵聽並接受到此套接字的連接，返回一個socket對象
            InputStream is = s.getInputStream();
//獲取到輸入流 
            BufferedReader br = new BufferedReader(new InputStreamReader(is));
            byte[] buf = new byte[1024];
//接收收到的數據
            int line = 0;
            while((line=is.read(buf))!=-1){
                System.out.println(new String(buf,0,line));
//將接收到的數據在控制台輸出
            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        
        
    }
    
}

四、運行結果