myserver.java

JavaSocket套接字TCP通讯的代码

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

public class MyServer {
	public static void main(String[] args) throws IOException {
		ServerSocket s = new ServerSocket(8658);
		System.out.println("开始：" + s);
		try {
			Socket socket = s.accept();
			try {
				System.out.println("连接接受" + socket);
				//建立BufferedReader存放从socket中取得的输入流
				BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
				//从socket中取得输出流，并构造PrintWriter对象
				PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);
				while (true) {
					//从输入流缓存区中读取数据存入变量str中
					String str = in.readLine();
					if (str.equals("q")){break;}
					System.out.println("对方说：" + str);
					System.out.print("我说：");
					BufferedReader is = new BufferedReader(new InputStreamReader(System.in));
					String input = new String();
					input = is.readLine().trim();
					out.println(input);
					out.flush();
				}
			} finally {
				System.out.println("关闭....");
				socket.close();
			}
		} finally {
			s.close();
		}
	}
}