初识Socket

客户端：

package Socket_Test;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.Socket;

public class LoginClient {
	public static void main(String[] args) throws Exception {

		// 建立客户端Socket连接,指定服务器的位置以及端口
		Socket socket = new Socket("localhost", 8800);
		// 得到Socket读写流
		OutputStream os = socket.getOutputStream();
		PrintWriter pw = new PrintWriter(os);
		// 输入流
		InputStream is = socket.getInputStream();
		BufferedReader br = new BufferedReader(new InputStreamReader(is));
		// 利用流按照一定的的协议对Socket进行读/写操作
		String info = "用户名:Tom/用户密码:123456";
		pw.write(info);
		pw.flush(); // 刷新
		socket.shutdownOutput();
		// 接受服务器的响应并打印显示
		String reply = null;
		while (!((reply = br.readLine()) == null)) {
			System.out.println("我是客户端，服务器的响应为：" + reply);
		}
		// 关闭资源
		br.close();
		is.close();
		pw.close();
		os.close();
		socket.close();
	}
}

服务器：

package Socket_Test;

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;

public class LoginServer {

	public static void main(String[] args) throws Exception {
		// 创建一个ServerSocket对象
		ServerSocket serverSocket = new ServerSocket(8800);
		// 使用accept()方法阻塞等待监听，获得新的连接
		Socket socket = serverSocket.accept();
		// 获得输入流
		InputStream is = socket.getInputStream();
		BufferedReader br = new BufferedReader(new InputStreamReader(is));
		// 获得输出流
		OutputStream os = socket.getOutputStream();
		PrintWriter pw = new PrintWriter(os);
		// 读取用户输入信息
		String info = null;
		while (!((info = br.readLine()) == null)) {
			System.out.println("我是服务器，用户信息为：" + info);
		}
		// 给客户端一个响应
		String reply = "welcome!";
		pw.write(reply);
		pw.flush(); // 刷新
		// 关闭资源
		os.close();
		br.close();
		is.close();
		socket.close();
		serverSocket.close();
	}
}