Java-Socket聊天室完整源代码

1、精选优质文档-倾情为你奉上说明：本人不才，Java初学者，自己平时也喜欢总结一些东西，然后与大家分享，同时希望得到Java高手的指正和指导，更希望能和广大的Java爱好者交朋友，共同学习Java，分享经验，一起进步。本人QQ：，非Java爱好者勿加，谢谢！以下代码实现的功能：在一个局域网内，两人在Eclipse的控制台上，可以点对点的进行聊天，并且某一方可以同时输入多句话，以下时实例图片：Server端的示意图：Client端的示意图：实现代码如下：服务端代码：import java.io.*;import .*;public class ServerTest3 public static v

2、oid main(String args) throws Exception / 设置sever端的链接ServerSocket s = new ServerSocket(8888);Socket s1 = s.accept();/ sever等待链接System.out.println(s1.getInetAddress().getHostAddress()+"上线了");/ 实例化输出流DataOutputStream dos = new DataOutputStream(s1.getOutputStream();/ 实例化输入流DataInputStream dis

3、= new DataInputStream(s1.getInputStream();/ 实例化两个线程的对象Thread msr = new MyServerReader(dis);Thread msw = new MyServerWriter(dos);/ 启动线程msr.start();msw.start();/ 创建一个线程用来进行接收,读取数据class MyServerReader extends Thread private DataInputStream dis;public MyServerReader(DataInputStream dis) this.dis = dis;p

4、ublic void run() String msg;try while (true) msg = dis.readUTF();System.out.println("客户端说:" + msg);if (msg.equals("bye") System.out.println("客户端下线,程序退出");System.exit(0); catch (IOException e) System.out.println(e);/ 创建一个进程用来写入并发送数据class MyServerWriter extends Thread pri

5、vate DataOutputStream dos;public MyServerWriter(DataOutputStream dos) this.dos = dos;public void run() BufferedReader br = new BufferedReader(new InputStreamReader(System.in);String msg;try while (true) msg = br.readLine();dos.writeUTF(msg);if (msg.equals("bye") System.out.println("自己

6、下线,程序退出");System.exit(0); catch (IOException e) System.out.println(e);客户端代码：import java.io.*;import .*;public class ClientTest3 public static void main(String args) throws Exception, Exception / 链接sever端Socket s1 = new Socket("127.0.0.1", 8888);/ 实例化输入流DataInputStream dis = new DataIn

7、putStream(s1.getInputStream();/ 实例化输出流DataOutputStream dos = new DataOutputStream(s1.getOutputStream();/ 实例化两个进程Thread mcr = new MyClientReader(dis);Thread mcw = new MyClientWriter(dos);/ 启动两个进程mcr.start();mcw.start();/ 创建一个线程用来进行接收读取数据class MyClientReader extends Thread private DataInputStream dis;

8、public MyClientReader(DataInputStream dis) this.dis = dis;public void run() String msg;try while (true) msg = dis.readUTF();System.out.println("服务端说:" + msg);if (msg.equals("bye") System.out.println("服务端下线,程序退出");System.exit(0); catch (IOException e) System.out.println(

9、e);/ 创建一个进程用来写入并发送数据class MyClientWriter extends Thread private DataOutputStream dos;public MyClientWriter(DataOutputStream dos) this.dos = dos;Overridepublic void run() BufferedReader br = new BufferedReader(new InputStreamReader(System.in);String msg;try while (true) msg = br.readLine();dos.writeUTF(msg);