黑马程序员技术交流社区

标题: 控制台聊天小程序代码 [打印本页]
作者: 周博文    时间: 2015-8-17 14:08
标题: 控制台聊天小程序代码
发送端：
  1. import java.io.BufferedReader;
  2. import java.io.IOException;
  3. import java.io.InputStreamReader;
  4. import java.io.Reader;
  5. import java.net.DatagramPacket;
  6. import java.net.DatagramSocket;
  7. import java.net.InetAddress;

  9. /*
  10. * 发送端程序：用于发送信息
  11. */
  12. public class SendMessage implements Runnable {
  13.         /*
  14.          * 发送端成员变量： socket对象 目的地ip地址 通信端口号
  15.          */
  16.         private DatagramSocket socket;
  17.         private InetAddress ip;
  18.         private int port;

  20.         public SendMessage(DatagramSocket socket, InetAddress ip, int port) {
  21.                 super();
  22.                 this.socket = socket;
  23.                 this.ip = ip;
  24.                 this.port = port;
  25.         }

  27.         @Override
  28.         public void run() {
  29.                 // 缓冲输入流用于读取用户输入
  30.                 Reader in = new InputStreamReader(System.in);
  31.                 BufferedReader reader = new BufferedReader(in);
  32.                 while (true) {
  33.                         try {
  34.                                 // 读取用户输入，并打包数据
  35.                                 String line = reader.readLine();
  36.                                 int length = line.getBytes().length;
  37.                                 DatagramPacket dp = new DatagramPacket(line.getBytes(), length, ip, port);
  38.                                 // 发送数据报包
  39.                                 socket.send(dp);
  40.                                 // 如果输入886，结束循环
  41.                                 if("886".equals(line)){
  42.                                         break;
  43.                                 }
  44.                                
  45.                         } catch (IOException e) {
  46.                                 e.printStackTrace();
  47.                         }
  48.                 }
  49.                 // 关闭资源
  50.                 try {
  51.                         reader.close();
  52.                         socket.close();
  53.                 } catch (IOException e) {
  54.                         e.printStackTrace();
  55.                 }
  56.         }

  58. }
复制代码

接收端：
  1. import java.io.IOException;
  2. import java.net.DatagramPacket;
  3. import java.net.DatagramSocket;

  5. /*
  6. * 接收端程序：用于接收信息
  7. */
  8. public class ReceiveMessage implements Runnable {
  9.         /*
  10.          * 接收端成员变量： 接收端socket对象
  11.          */
  12.         private DatagramSocket socket;

  14.         public ReceiveMessage(DatagramSocket socket) {
  15.                 super();
  16.                 this.socket = socket;
  17.         }

  19.         @Override
  20.         public void run() {
  21.                 while (true) {
  22.                         // 接收数据并打印到控制台
  23.                         DatagramPacket dp = new DatagramPacket(new byte[1024], 0, 1024);
  24.                         try {
  25.                                 socket.receive(dp);
  26.                         } catch (IOException e) {
  27.                                 e.printStackTrace();
  28.                         }
  29.                         String data = new String(dp.getData(), 0, dp.getLength());
  30.                         System.out.println(dp.getAddress().getHostName() + "-" + dp.getPort() + " : " + data);
  31.                        
  32.                 }
  33.         }

  35. }
复制代码

客户端1：
  1. import java.io.IOException;
  2. import java.net.DatagramSocket;
  3. import java.net.InetAddress;

  5. public class Client1 {
  6.         public static void main(String[] args) throws IOException {
  7.                 SendMessage sm = new SendMessage(new DatagramSocket(), InetAddress.getByName("kaven-PC"), 10010);
  8.                 ReceiveMessage rm = new ReceiveMessage(new DatagramSocket(10011));
  9.                
  10.                 Thread t1 = new Thread(sm);
  11.                 Thread t2 = new Thread(rm);
  12.                
  13.                 t1.start();
  14.                 t2.start();
  15.         }
  16. }
复制代码

客户端2：

  1. import java.io.IOException;
  2. import java.net.DatagramSocket;
  3. import java.net.InetAddress;

  5. public class Client1 {
  6.         public static void main(String[] args) throws IOException {
  7.                 SendMessage sm = new SendMessage(new DatagramSocket(), InetAddress.getByName("kaven-PC"), 10010);
  8.                 ReceiveMessage rm = new ReceiveMessage(new DatagramSocket(10011));
  9.                
  10.                 Thread t1 = new Thread(sm);
  11.                 Thread t2 = new Thread(rm);
  12.                
  13.                 t1.start();
  14.                 t2.start();
  15.         }
  16. }
复制代码



作者: 周博文    时间: 2015-8-17 14:15
运行结果：
作者: ℃葫芦    时间: 2015-8-17 16:57
自己跟自己说话呢？
作者: pengbeilin    时间: 2015-8-17 17:43
这个年代 自娱自乐也需要技术
作者: boboyuwu    时间: 2015-8-17 18:27
不错不错要是我会建立个图形化界面有有趣很多呵呵
作者: 周博文    时间: 2015-8-17 20:12
℃葫芦 发表于 2015-8-17 16:57
自己跟自己说话呢？

。。。。。。。



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