用JAVA SOCKET编程，读服务器几个字符，再写入本地显示

问题：用JAVA SOCKET编程，读服务器几个字符，再写入本地显示。

 

（1）客户端

package com.socket;

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

//编写一段Java代码，用JAVA SOCKET编程，读服务器几个字符，再写入本地显示。
public class Client {

	public static void main(String[] args) {

		Socket clientSocket = null;

		InputStreamReader input = null;// 字节流到字符流的桥梁

		BufferedReader in = null;

		OutputStream output = null;

		PrintWriter out = null;

		InputStreamReader consoleInput = null;// 字节流到字符流的桥梁

		BufferedReader consoleIn = null;

		try {
			// 创建一个客户端
			clientSocket = new Socket("127.0.0.1", 400);

			// 获取客户端的读入流并进行包装
			input = new InputStreamReader(clientSocket.getInputStream());
			in = new BufferedReader(input);

			// 获取客户端的输出流并进行包装
			output = clientSocket.getOutputStream();
			out = new PrintWriter(output, true);// 一定要刷新

			// 用户从客户端输入信息(对流进行包装)
			consoleInput = new InputStreamReader(System.in);
			consoleIn = new BufferedReader(consoleInput);

			// 用户从客户端输入信息
			String consoleStr = consoleIn.readLine();

			// 用户输入exit停止客户端
			while (!consoleStr.equals("exit")) {

				System.out.println("client:" + consoleStr);
				out.println(consoleStr);// 写到服务端
				System.out.println("server :"+in.readLine());//从服务器读取信息
				consoleStr = consoleIn.readLine();// 用户继续从客户端输入信息

			}

			// 输入exit时也关闭服务端
			out.println("exit");

		} catch (Exception e) {

			e.printStackTrace();

		} finally {
			// 关闭流

			if (consoleIn != null) {
				try {
					consoleIn.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (consoleInput != null) {
				try {
					consoleInput.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (out != null) {

				out.close();
			}

			if (output != null) {
				try {
					output.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (in != null) {
				try {
					in.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (input != null) {
				try {
					input.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (clientSocket != null) {
				try {
					clientSocket.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}
		}
	}

}

 

 

（2）服务端

package com.socket;

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

//客户端
public class Server {

	public static void main(String[] args) {

		ServerSocket server = null;

		Socket clientSocket = null;

		InputStreamReader input = null;// 字节流到字符流的桥梁

		BufferedReader in = null;

		OutputStream output = null;

		PrintWriter out = null;

		try {
			// 创建一个服务端
			server = new ServerSocket(400);

			// 接收一个客户端
			clientSocket = server.accept();

			// 获取客户端的读入流并进行包装
			input = new InputStreamReader(clientSocket.getInputStream());
			in = new BufferedReader(input);

			// 获取客户端的输出流并进行包装
			output = clientSocket.getOutputStream();
			out = new PrintWriter(output, true);// 一定要刷新

			// 从客户端输入信息
			String str = in.readLine();

			//System.out.println(str);

			while (!str.equals("exit")) {

				out.println(str);// 把从客户端读取的信息返回给客户端
				str = in.readLine();// 继续从客户端读取信息

			}

		} catch (Exception e) {

			e.printStackTrace();
			
		} finally {
			// 关闭流

			if (out != null) {

				out.close();
			}

			if (output != null) {
				try {
					output.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (in != null) {
				try {
					in.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (input != null) {
				try {
					input.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (clientSocket != null) {
				try {
					clientSocket.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}

			if (server != null) {
				try {
					server.close();

				} catch (IOException e) {

					e.printStackTrace();
				}
			}
		}
	}

}