黑马程序员技术交流社区

标题: 【记录】代码练习-多线程实现聊天室程序 [打印本页]
作者: Kevin.Kang    时间: 2015-8-7 19:12
标题: 【记录】代码练习-多线程实现聊天室程序
测试类：
  1. package com.kxg_05;

  3. import java.io.IOException;
  4. import java.net.DatagramSocket;

  6. public class ChatRoom {
  7.         public static void main(String[] args) throws IOException {
  8.                 DatagramSocket dsSend = new DatagramSocket();
  9.                 DatagramSocket dsReceive = new DatagramSocket(48264);

  11.                 SendThread st = new SendThread(dsSend);
  12.                 ReceiveThread rt = new ReceiveThread(dsReceive);

  14.                 Thread t1 = new Thread(st);
  15.                 Thread t2 = new Thread(rt);

  17.                 t1.start();
  18.                 t2.start();
  19.         }
  20. }
复制代码
发送端类：
  1. package com.kxg_05;

  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;
  6. import java.net.InetAddress;
  7. import java.util.Scanner;

  9. public class SendThread implements Runnable {
  10.         private DatagramSocket ds;

  12.         public SendThread(DatagramSocket ds) {
  13.                 this.ds = ds;
  14.         }

  16.         @Override
  17.         public void run() {
  18.                 try {
  19.                 Scanner sc = new Scanner(System.in);
  20.                 String s = null;
  21.                         while ((s = sc.nextLine()) != null) {
  22.                         byte[] bys = s.getBytes();
  23.                         DatagramPacket dp = new DatagramPacket(bys, bys.length,
  24.                                         InetAddress.getByName("10.164.22.254"), 48264);
  25.                                 ds.send(dp);
  26.                                 if (s.equals("我下了")) {
  27.                                         break;
  28.                                 }
  29.                         }
  30.                         ds.close();
  31.                 } catch (IOException e) {
  32.                         e.printStackTrace();
  33.                 }
  34.         }
  35. }
复制代码

接收端类：
  1. package com.kxg_05;

  3. import java.io.IOException;
  4. import java.net.DatagramPacket;
  5. import java.net.DatagramSocket;

  7. public class ReceiveThread implements Runnable {
  8.         private DatagramSocket ds;

  10.         public ReceiveThread(DatagramSocket ds) {
  11.                 this.ds = ds;
  12.         }

  14.         @Override
  15.         public void run() {
  16.                 try {
  17.                         while (true) {
  18.                                 byte[] bys = new byte[1024];

  20.                                 DatagramPacket dp = new DatagramPacket(bys, bys.length);

  22.                                 ds.receive(dp);

  24.                                 String ip = dp.getAddress().getHostAddress();

  26.                                 String s = new String(dp.getData(), 0, dp.getLength());

  28.                                 System.out.println(ip + ":" + s);
  29.                         }
  30.                 } catch (IOException e) {
  31.                         e.printStackTrace();
  32.                 }
  33.         }
  34. }
复制代码







欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2