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模型使用一個(gè)工具實(shí)現(xiàn)TCP編程，這個(gè)工具叫做Socket，服務(wù)端叫ServerSocket,
		try {
			ServerSocket ss = new ServerSocket(65535);//這個(gè)端口號(hào) 寫(xiě)死 固定的
			//這個(gè)是客戶端發(fā)送上來(lái)的鏈接，服務(wù)器使用這個(gè)鏈接做數(shù)據(jù)處理
			Socket s = ss.accept();
			//分別是兩個(gè)指針對(duì)當(dāng)前聯(lián)機(jī)的輸入輸出流
			OutputStream os = s.getOutputStream();
			InputStream is = s.getInputStream();			
			//改變輸入輸出流的狀態(tài)（套一個(gè)其它流）
			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  鏈接到那個(gè)主機(jī)上 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是面向報(bào)文的，所以數(shù)據(jù)傳輸過(guò)程中，是不需要建立鏈接的，只要有對(duì)應(yīng)的報(bào)文，就可以指揮網(wǎng)卡去發(fā)送這個(gè)數(shù)據(jù)包
		//但是對(duì)于服務(wù)器來(lái)說(shuō)，UDP雖然沒(méi)有建立鏈接，卻需要在對(duì)應(yīng)的端口上進(jìn)行監(jiān)聽(tīng)，否則是有問(wèn)題的
		//DatagramSocket,這個(gè)類型是JAVA對(duì)于UDP實(shí)現(xiàn)的一個(gè)網(wǎng)絡(luò)套接字，當(dāng)我們需要使用UDP傳輸內(nèi)容的時(shí)候，只需要?jiǎng)?chuàng)建一個(gè)
		//DatagramSocket,對(duì)象就可以了，不用指定這個(gè)對(duì)象是否是服務(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ù) 拆開(kāi)包裹
				System.out.println(new String(b));	
				System.out.println(p.getAddress() + "說(shuō) ： " + new String(b));
				p.setData("你開(kāi)心就好".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();
		}		
	}
}