自由聊天程序

package test;

import java.io.*;
import java.net.Socket;

public class TestClient
{
	public static void main(String[] args)
	{
		try
		{
			Socket s=new Socket("localhost",8888);
			System.out.println("已经和服务器建立连接");
			DataInputStream dis=new DataInputStream(s.getInputStream());
			DataOutputStream dos=new DataOutputStream(s.getOutputStream());
			new MyClientReader(dis).start();
			new MyClientWriter(dos).start();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
}
class MyClientReader extends Thread
{
	private DataInputStream dis;

	public MyClientReader(DataInputStream dis)
	{
		super();
		this.dis = dis;
	}
	public void run()
	{
		String message;
		try
		{
			while(true)
			{
				message=dis.readUTF();
				System.out.println("服务端说:"+message);
				if(message.equals("88"))
				{
					System.out.println("对方已经下线,程序退出");
					System.exit(0);
				}
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}
class MyClientWriter extends Thread
{
	private DataOutputStream dos;

	public MyClientWriter(DataOutputStream dos)
	{
		super();
		this.dos = dos;
	}
	public void run()
	{
		BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
		String message;
		try
		{
    		while(true)
    		{
    			System.out.print("请输入消息:");
    			message=br.readLine();
    			dos.writeUTF(message);
    			if(message.equals("88"))
    			{
    				System.out.println("自己下线,程序退出");
    				System.exit(0);
    			}
    		}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
}

 

package test;

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;

public class TestServer
{
	public static void main(String[] args)
	{
		System.out.println("服务器启动成功");
		try
		{
			ServerSocket ss=new ServerSocket(8888);
			Socket s=ss.accept();
			System.out.println("已经和客户端建立连接");
			OutputStream os=s.getOutputStream();
			DataOutputStream dos=new DataOutputStream(os);
			InputStream is=s.getInputStream();
			DataInputStream dis=new DataInputStream(is);
			new MyServerReader(dis).start();
			new MyServerWriter(dos).start();
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
}
class MyServerReader extends Thread
{
	private DataInputStream dis;

	public MyServerReader(DataInputStream dis)
	{
		super();
		this.dis = dis;
	}
	public void run()
	{
		String message;
		try
		{
			while(true)
			{
				message=dis.readUTF();
				System.out.println("客户端说:"+message);
				if(message.equals("88"))
				{
					System.out.println("对方下线,程序退出");
					System.exit(0);
				}
			}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
	
}
class MyServerWriter extends Thread
{
	private DataOutputStream dos;

	public MyServerWriter(DataOutputStream dos)
	{
		super();
		this.dos = dos;
	}
	public void run()
	{
		BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
		String message;
		try
		{
    		while(true)
    		{
    			message=br.readLine();
    			dos.writeUTF(message);
    			if(message.equals("88"))
    			{
    				System.out.println("自己下线,程序退出");
    				System.exit(0);
    			}
    		}
		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}