package com.lanou.test;
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;
import java.util.Scanner;
public class TCPServer {
	public static void main(String[] args) {
		//JAVA的TCP編程中，BIO模型使用一個工具實現(xiàn)TCP編程，這個工具叫做Socket，服務(wù)端叫ServerSocket,
		try {
			ServerSocket ss = new ServerSocket(65535);//這個端口號 寫死 固定的
			//這個是客戶端發(fā)送上來的鏈接，服務(wù)器使用這個鏈接做數(shù)據(jù)處理
			Socket s = ss.accept();
			//分別是兩個指針對當前聯(lián)機的輸入輸出流
			OutputStream os = s.getOutputStream();
			InputStream is = s.getInputStream();			
			//改變輸入輸出流的狀態(tài)（套一個其它流）
			PrintWriter pw = new PrintWriter(os);
			Scanner scanner = new Scanner(System.in);
			BufferedReader br = new BufferedReader(new InputStreamReader(is));
			while(true) {
				String str= scanner.nextLine();	//nextline  阻塞式代碼
				pw.println(str);
				pw.flush();
				if(str.equals("")) {
					break;
				}
				str = br.readLine();
				System.out.println("我是服務(wù)器，我收到客戶端消息" + str);
				if(str.equals("")) {
					break;
				}	
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.test;
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;
import java.util.Scanner;
public class TCPClient {
	public static void main(String[] args) {
		//客戶端，直接使用Sockert工具
		try {
			Socket s = new Socket("127.0.0.1", 65535);
			// host  鏈接到那個主機上 String的參數(shù)       port端口 
			InputStream is = s.getInputStream();
			OutputStream os = s.getOutputStream();
			BufferedReader br = new BufferedReader(new InputStreamReader(is));
			PrintWriter pw = new PrintWriter(os);
			Scanner scanner = new Scanner(System.in);
			String str;
			while(!(str = br.readLine()).equals("")) {	
				System.out.println("客戶端收到"+str);
				str = scanner.nextLine();
				pw.println(str);
				pw.flush();
				if(str.equals("")) {
					break;
				}
			}
		} catch (UnknownHostException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;
public class UDP {
	public static void main(String[] args) {
		//UDP是面向報文的，所以數(shù)據(jù)傳輸過程中，是不需要建立鏈接的，只要有對應(yīng)的報文，就可以指揮網(wǎng)卡去發(fā)送這個數(shù)據(jù)包
		//但是對于服務(wù)器來說，UDP雖然沒有建立鏈接，卻需要在對應(yīng)的端口上進行監(jiān)聽，否則是有問題的
		//DatagramSocket,這個類型是JAVA對于UDP實現(xiàn)的一個網(wǎng)絡(luò)套接字，當我們需要使用UDP傳輸內(nèi)容的時候，只需要創(chuàng)建一個
		//DatagramSocket,對象就可以了，不用指定這個對象是否是服務(wù)（區(qū)別TCP的ServerSocket）	
		try {
			DatagramSocket socket = new DatagramSocket(10086);
			byte[] b = new byte[1024];
			DatagramPacket p =new DatagramPacket(b, b.length);
			while(true) {
				socket.receive(p);
				b = p.getData();//拿出數(shù)據(jù) 拆開包裹
				System.out.println(new String(b));	
				System.out.println(p.getAddress() + "說 ： " + new String(b));
				p.setData("你開心就好".getBytes());
				socket.send(p);
			}		
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}
}

package com.lanou.udp;
import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketAddress;
import java.net.SocketException;
public class UDPClient {
	public static void main(String[] args) {
		try {
			DatagramSocket socket = new DatagramSocket();
			String str = "我是客戶端  ";
			DatagramPacket p = new DatagramPacket(str.getBytes(), str.getBytes().length);
			p.setSocketAddress(new InetSocketAddress("127.0.0.1", 10086));
			socket.send(p);
			socket.receive(p);
			System.out.println(new String(p.getData()));
		} catch (SocketException e) {
			e.printStackTrace();
		} catch (IOException e) {
			e.printStackTrace();
		}		
	}
}