Java 全面掌握网络编程篇

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();
		}
	}

}