浪費了“黃金五年”的Java程式設計師，還有救嗎？ >>>   

TCP 網路通訊

TCP：可靠的傳輸層協議

服務端：

package com.zhiwei.net;

import java.io.DataInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;

/***
 * 簡單的TCP服務端類
 * ①：建立ServerSocket：資料碼頭
 * ②：建立Socket：資料碼頭集裝箱：真正的資料集中站
 * ③：解析Socket獲取InputStream和OutputStream物件
 *   InputStream和OutputStream都和同一個Socket關聯，
 *   InputStream:負責接受客戶端的資料
 *   OutputStream：負責對客戶端做出響應
 *注：Tomcat的Http請求也是利用該原理，聯結器接受客戶端請求負責建立HttpRequest和HttpResponse物件(本質解析Socket),然後呼叫處理器處理
 * @author Yang Zhiwei
 *
 */
public class SimpleTCPServer {
    
	private static boolean flag=true;  //伺服器開啟標誌
	
	public static void main(String[] args) throws Exception {
		
		ServerSocket serverSocket=new ServerSocket(8888);
		
		while(flag){
		//當服務端程式執行到該階段時執行緒阻塞，直到接受客戶端請求才向下流轉(Debug可以檢視)
		Socket socket=serverSocket.accept();
		new ServerService(socket).run();
		
		}
		serverSocket.close();
	}
	
}

class ServerService implements Runnable{
    
	private Socket socket=null;
	
	public  ServerService(Socket socket) {
		this.socket=socket;
	}
	
	@Override
	public void run() {
		
		InputStream is = null;
		DataInputStream dis = null;
		try {
			is = socket.getInputStream();
			dis=new DataInputStream(is);
			System.out.println("客戶端請求內容："+dis.readUTF());
			
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
            try {
            	if(dis!=null){
				dis.close();
            	}
				socket.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}


 

客戶端：

package com.zhiwei.net;

import java.io.DataOutputStream;
import java.io.OutputStream;
import java.net.Socket;
/**
 * TCP客戶端的建立
 * ①：建立Socket：資料集裝箱：必須指定服務端的地址
 * ②：解析Socket資料：負責和服務端的具體資料通訊
 * @author Yang Zhiwei
 *
 */
public class SimpleTCPClient {

	public static void main(String[] args) throws Exception {
		
		Socket socket=new Socket("127.0.0.1", 8888);
		
		OutputStream os=socket.getOutputStream();
	    DataOutputStream dos=new DataOutputStream(os);
		dos.writeUTF("Hello Server.....");
		
		dos.close();
		socket.close();
	}
}

 

結果：

---

UDP 網路通訊

UDP是無狀態的傳輸層協議，如果對資料的要求不高完全可以使用UDP協議，減少資源的浪費，UDP不保證資料的可靠性，常見的QQ通訊工具是使用UDP協議的，只是在應用層的基礎上保證QQ訊息的不丟失，並不是採用TCP的傳輸協議

服務端：

package com.zhiwei.net;

import java.net.DatagramPacket;
import java.net.DatagramSocket;

//伺服器端接受客戶端資料
public class UDPServer {

	public static void main(String[] args) throws Exception{
		
		//建立資料接收碼頭，只接受和客戶端約定的3000埠的資料
		DatagramSocket ds=new DatagramSocket(3000);
		
		//建立資料接收的資料緩衝區
        byte[] buf=new byte[1024];
		DatagramPacket dp=new DatagramPacket(buf,1024);
		
		//接受來自埠1024的資料包，並存儲在集裝箱datagramPacket中：注意一旦伺服器開啟，就會自動監聽3000埠，如果 沒有資料，則進行阻塞
		ds.receive(dp);
		
		//解析資料包中的資訊
		String data=new String(dp.getData(),0,dp.getLength());
		String ip=dp.getAddress().getHostAddress();
		int port=dp.getPort();
		
		System.out.println("ip地址："+ip+" 埠號："+port+" 訊息："+data);
	    ds.close();
	}

}

 

客戶端：

package com.zhiwei.net;

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;

//傳送資料給伺服器：注意若伺服器端未開啟就傳送資料，資料包很可能會丟失
public class UDPClient {

	public static void main(String[] args) throws Exception {
        
		//資料包套接字：相當於碼頭，專門處理通訊資料及進行資料轉發設定的
		DatagramSocket ds=new DatagramSocket();
		
		String message="Hello Java World!";
		
		//資料報包:類似於集裝箱，用來儲存所有的資料資訊
		DatagramPacket dp=new DatagramPacket(
				message.getBytes(),   //資料都是已位元組資料進行傳送的，因此需要將資料進行轉換
				message.length(), //傳送資料的長度
				InetAddress.getByName("127.0.0.1"),  //傳送資料的源ip地址
				3000   //傳送資料的埠號
				);
		
		ds.send(dp);  //資料包通過碼頭DatagramSocket傳送出去
		ds.close();	  //資料傳送之後關閉通道，減少資源浪費
	}
}

結果：

相關推薦