myserversocket.java

自己编写的Java学习代码

import java.io.*;
import java.net.*;
public class MyServerSocket implements Runnable
{

	private BufferedReader in ;
	private String msg ;
	public MyServerSocket(BufferedReader in){
		this.in=in;
		new Thread(this,"ServerSocket").start();
	}
	
	//负责接受客户端信息
	public void run(){
			while(true){
				try{
					//接受
					msg = in.readLine();
					System.out.println("C=>"+msg);
					
					if(msg.equals("bye")){
						break;
					}
				}catch(Exception e){

				}
			}
	}

	public static void main(String args[])throws Exception{
		ServerSocket serverSocket = new ServerSocket(8000);
		Socket socket = null;
		
		BufferedReader in = null;
		BufferedWriter out = null;
		BufferedReader stdin = null;

		System.out.println("***等待客户端连接***");
		socket = serverSocket.accept();
		System.out.println("***客户端连接成功***");
		
		//获得输入输出流
		in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
		out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
		
		new MyServerSocket(in);
		
		while(true){
			String msg = "";
			//发送
			stdin = new BufferedReader(new InputStreamReader(System.in));
			System.out.print("S=>");
			msg = stdin.readLine();
			out.write(msg+"\n");
			out.flush();
			if(msg.equals("bye")){
					break;
			}
		}


		//关闭
		in.close();
		out.close();
		socket.close();

	}
}