網路程式設計：利用網路將不同計算機資料進行交換

網路三要素：

IP地址   +   埠 =Socket

協議 ：UDP，TCP     

inetAddress類的使用

public class InetAddressDemo {

	public static void main(String[] args) throws Exception {
		// TODO Auto-generated method stub
		InetAddress address = InetAddress.getByName("");
		System.out.println(address.getHostAddress());
		System.out.println(address.getHostName());
		InetAddress localHost = InetAddress.getLocalHost();
		System.out.println(localHost);
	}

}
 

UDP和TCP協議

UDP：將資料來源和目的封裝在資料包中，不需要建立連線，每個資料包大小在64K內，無連線，是不可靠協議，但是速度很快。

TCP:建立連線，形成傳輸資料的通道，在連線中進行大資料量的傳輸；通過三次握手完成連線，是可靠協議，但是效率會稍低。

Socket：應用層和傳輸層之間的橋樑。下面的底層已經封裝好了，我們只需要用Socket進行操作就行了。

Socket原理機制：

通訊的兩端都有Socket

網路通訊其實就是Socket間的通訊

資料在兩個Socket之間通過IO傳輸

UDP傳輸伺服器端編寫

public class Server {

	public static void main(String[] args) throws Exception {
//		建立一個服務端Socket並監聽指定埠
		DatagramSocket ds = new DatagramSocket(8888);
//		接收資料，並將資料放在資料包中
		byte[] buf =new byte[64*1024];
		int length = buf.length;
		DatagramPacket p = new DatagramPacket(buf, length);
		ds.receive(p);
//		將包中的資料取出來
		byte[] data=p.getData();//獲取的是接受到的資料
		InetAddress address = p.getAddress();//接受傳送過來的主機地址
		int port = p.getPort();//獲取埠號
		String ip = address.getHostAddress();//獲取的是客戶端的ip地址
		int dataLength = p.getLength();
//		將資料轉換成字串
		String result = new String(data,0,dataLength);
		System.out.println("ip="+ip+",port="+port+",result="+result);
//		關閉資源
		ds.close();
	}

}
 

UDP客戶端客戶端編寫

public class Client {

	public static void main(String[] args) throws Exception {
		DatagramSocket ds = new DatagramSocket();
		byte[] buf = "UDP傳送訊息".getBytes();//包資料
		int length=buf.length;//包長度
		InetAddress address=InetAddress.getByName("127.0.0.1");//目的地址
		int port=8888;//目的埠號
		DatagramPacket p=new DatagramPacket(buf, length, address, port);
		// 呼叫Socket的傳送方法
		ds.send(p);
		ds.close();
	}

}
 

l聊天室初級版客戶端

public class Client {

	public static void main(String[] args) throws Exception {
		DatagramSocket ds = new DatagramSocket();
		InetAddress address = InetAddress.getByName("127.0.0.1");
		Scanner sc = new Scanner(System.in);
		String line;
		while (!(line = sc.nextLine()).equals("886")) {
			byte[] buf = line.getBytes();
			DatagramPacket packet = new DatagramPacket(buf, buf.length, address, 8888);
			ds.send(packet);
		}
		ds.close();
	}
}

public class Server {

	public static void main(String[] args) throws Exception {
		DatagramSocket socket = new DatagramSocket(8888);
//		迴圈接受客戶端傳送的內容
		byte[] buf=new byte[64*1024];
		while(true){
			DatagramPacket packet = new DatagramPacket(buf, buf.length);
			//接受客戶端資料並存儲到包中
			socket.receive(packet);
//			從資料包中取出內容
			byte[] data = packet.getData();
			int length = packet.getLength();
			String ip = packet.getAddress().getHostAddress();
//			將位元組陣列的形式內容轉化成字串
			String result = new String(data,0,length);
			System.out.println("ip="+ip+",result="+result);
		}
	}

}

注意點：伺服器端建立Socket直接帶埠號

如何和在一個介面上？

運用執行緒。讓這倆個程式執行在同一個主執行緒內。

此時會報錯。Command+option+z，try...catch一下。第一個意思是分別catch，第二個是 catch所有的Exception。

一個完整的UDP聊天室

客戶端

public class ClientRunnable implements Runnable {

	private String ip;
	private int port;

	public ClientRunnable(String ip, int port) {
		this.ip = ip;
		this.port = port;
	}

	@Override
	public void run() {
		DatagramSocket ds = null;
		try {
			ds = new DatagramSocket();
			InetAddress address = InetAddress.getByName(ip);
			Scanner sc = new Scanner(System.in);
			String line;
			while (!(line = sc.nextLine()).equals("886")) {
				byte[] buf = line.getBytes();
				DatagramPacket packet = new DatagramPacket(buf, buf.length, address, port);
				ds.send(packet);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		} finally {
			if (ds != null) {
				ds.close();
			}
		}
	}
}

public class ServerRunnable implements Runnable {

	private int port;

	public ServerRunnable(int port) {
		this.port = port;
	}

	@Override
	public void run() {
		try {
			DatagramSocket socket = new DatagramSocket(port);
//		迴圈接受客戶端傳送的內容
			byte[] buf=new byte[64*1024];
			while(true){
				DatagramPacket packet = new DatagramPacket(buf, buf.length);
				//接受客戶端資料並存儲到包中
				socket.receive(packet);
//			從資料包中取出內容
				byte[] data = packet.getData();
				int length = packet.getLength();
				String ip = packet.getAddress().getHostAddress();
//			將位元組陣列的形式內容轉化成字串
				String result = new String(data,0,length);
				System.out.println("ip="+ip+",result="+result);
			}
		} catch (IOException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}

public class ChatRoom {

	public static void main(String[] args) {
//		先啟動服務端聊天執行緒，再啟動客戶端聊天執行緒
		ClientRunnable clientRunnable = new ClientRunnable("127.0.0.1",8888);
		ThreadPoolUtils.execute(clientRunnable);
		ServerRunnable serverRunnable = new ServerRunnable(8888);
		ThreadPoolUtils.execute(serverRunnable);
	}

}

public class ThreadPoolUtils {
	private static ExecutorService threadpool = Executors.newCachedThreadPool();

	public static void execute(Runnable command) {
		threadpool.execute(command);
	}
}