Java 全面掌握网络编程篇

目录

• 计算机网络
• 网络模型
• 客户机服务器模式(Client/Server)
• TCP/IP的概念和实现
• TCP三次握手(Three-way handshake)
• TCP编程
• UDP的概念和实现
• UDP编程
• TCP和UDP的区别
• 聊天室

• 服务器处理线程
• 客户端处理线程
• 服务器
• 客户端
• 效果

ServerSocket ss = new ServerSocket(100);

Socket s = ss.accept();
String ip = s.getInetAddress().getHostAddress();

Socket s = new Socket("localhost",100);

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.io.Reader;
import java.net.Socket;
import java.net.SocketException;
import java.util.Scanner;
public class ServerTask  implements Runnable{
	private Socket socket;
	public ServerTask(Socket socket) {
		// TODO 自动生成的构造函数存根
		this.socket = socket;
	}
	@Override
	public void run() {
		// TODO 自动生成的方法存根
		//建立通信后所执行的内容
		System.out.println("欢迎【"+socket.getRemoteSocketAddress().toString()+"】进入聊天室");
		//构建读取缓冲
		BufferedReader br =null;
		//http响应写入
		PrintWriter pw = null;
		try {
			//获取客户端输入的信息 字节流缓冲成字符流
			br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
			String msg;
			while((msg=br.readLine()) != null) {
				msg = "【"+socket.getRemoteSocketAddress().toString()+"】说"+msg;
				//输出客户端信息
				System.out.println(msg);
				//服务器接收到客户端的消息发送消息给客户端
				Scanner scanner = new Scanner(System.in);
				System.out.println("请输入要发送的信息！");
				pw = new PrintWriter(socket.getOutputStream(),true);
				pw.println("服务器说："+scanner.nextLine());
				pw.flush();				
			}	
		}catch (SocketException e) {
			// TODO: handle exception
			System.out.println(socket.getRemoteSocketAddress().toString()+"退出聊天室！");
		}	
		catch (Exception e) {
			// TODO: handle exception
		}
	}
}

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.PrintStream;
import java.io.PrintWriter;
import java.net.Socket;
import java.net.SocketException;
import java.util.Scanner;
public class ClientTask  implements Runnable{
	private Socket socket;
	public ClientTask(Socket socket) {
		// TODO 自动生成的构造函数存根
		this.socket = socket;
	}
	@Override
	public void run() {
		// TODO 自动生成的方法存根
		try {
				while(true) {
					Scanner scanner = new Scanner(System.in);
					System.out.println("请输入要发送的信息");
					//消息发送到服务器
					PrintWriter pw = new PrintWriter(socket.getOutputStream(),true);
					//br.readLine()读取的消息发送到服务器
					pw.println(scanner.nextLine());
					//读取服务器发送的消息
					BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
					System.out.println(br.readLine());
				}		
		}
		catch (Exception e) {
			// TODO: handle exception
		}
	}
}

import java.net.ServerSocket;
import java.net.Socket;
import com.qingsu.chat.Task.ServerTask;
public class ChatServer {
	public static void main(String[] args) {
		try {
			//创建服务端对象 监听一个窗口
			ServerSocket serverSocket = new ServerSocket(10622);
			System.out.println("服务器创建成功！端口号"+10622);
			//阻塞 直到有链接返回
			while(true) {
				Socket socket = serverSocket.accept();//获取客户端对象
				//启动一个线程处理该链接
				Thread thread = new Thread(new ServerTask(socket));
				thread.start();
			}		
		} catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
}

import java.net.Socket;
import com.qingsu.chat.Task.ClientTask;
public class ChatClient {
	public static void main(String[] args) {
		try {
			//创建客户端socket服务，把ip和端口作为地址传进构造函数
			Socket socket = new Socket("127.0.0.1",10622);
			//启动客户机线程处理
			Thread thread = new Thread(new ClientTask(socket));		
			thread.start();
		}catch (Exception e) {
			// TODO: handle exception
			e.printStackTrace();
		}
	}
}