黑马程序员技术交流社区

标题: 实现局域网消息的发送功能实现 [打印本页]
作者: 不安分的程序猿    时间: 2016-5-19 23:42
标题: 实现局域网消息的发送功能实现
  1. /**
  2. * @author 不安份的程序猿
  3. *
  4. */
  5. //UDP协议实现 输出数据
  6. public class DemoGet {
  7.         public static void main(String[] args) throws Exception {
  8.                 final DatagramSocket get = new DatagramSocket(9999); // 创建接口
  9.                 final boolean t = true;
  10.                 new Thread(new Runnable() {

  12.                         @Override
  13.                         public void run() {
  14.                                 while (t) {
  15.                                         // 接收set发送的消息
  16.                                         byte[] b = new byte[1024]; //
  17.                                         DatagramPacket dp = new DatagramPacket(b, b.length);// 将从b到b.length都进行打包
  18.                                         try {
  19.                                                 get.receive(dp);
  20.                                         } catch (IOException e) {
  21.                                                 // TODO Auto-generated catch block
  22.                                                 e.printStackTrace();
  23.                                         } // 接受这个包
  24.                                         int length = dp.getLength();// 获取这个包的长度
  25.                                         // System.out.println(new String(b,0,length)); //转化成字符串然后输出
  26.                                         System.out.println("消息是由" + dp.getAddress() + "发送的,端口是："
  27.                                                         + dp.getPort() + "内容是" + new String(b, 0, length));
  28.                                 }
  29.                         }
  30.                 }).start();
  31.                 new Thread(new Runnable() {

  33.                         @Override
  34.                         public void run() {
  35.                                 while (t) {
  36.                                         // 往set回复消息
  37.                                         try {
  38.                                                 Scanner sc = new Scanner(System.in);
  39.                                                 String str = sc.nextLine();
  40.                                                 DatagramPacket send = new DatagramPacket(
  41.                                                                 str.getBytes(), str.getBytes().length,
  42.                                                                 InetAddress.getLocalHost(), 6666);
  43.                                                 get.send(send);
  44.                                         } catch (IOException e) {
  45.                                                 // TODO Auto-generated catch block
  46.                                                 e.printStackTrace();
  47.                                         }
  48.                                 }
  49.                         }
  50.                 }).start();
  51.                 // get.close();
  52.         }
  53. }
复制代码
作者: 不安分的程序猿    时间: 2016-5-19 23:44


  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. //利用UDP协议编写 实现客户端和服务器
  10. //此类是输出端
  11. public class DemoSet {
  12.         public static void main(String[] args) throws Exception {
  13.                 final DatagramSocket set = new DatagramSocket(6666);
  14.                 final boolean t = true;
  15.                 new Thread(new Runnable() {

  17.                         @Override
  18.                         public void run() {
  19.                                 while (t) {
  20.                                         try {
  21.                                                 // 往服务器发送消息
  22.                                                 Scanner sc = new Scanner(System.in);
  23.                                                 String str = sc.nextLine();
  24.                                                 DatagramPacket dp = new DatagramPacket(str.getBytes(),
  25.                                                                 str.getBytes().length,
  26.                                                                 InetAddress.getLocalHost(), 9999);

  28.                                                 set.send(dp);
  29.                                         } catch (IOException e) {
  30.                                                 e.printStackTrace();
  31.                                         }
  32.                                 }
  33.                         }
  34.                 }).start();
  35.                 new Thread(new Runnable() {

  37.                         @Override
  38.                         public void run() {
  39.                                 while (t) {
  40.                                         // 从get类里面获取消息
  41.                                         byte[] b = new byte[1024];
  42.                                         DatagramPacket re = new DatagramPacket(b, b.length);
  43.                                         try {
  44.                                                 set.receive(re);
  45.                                         } catch (IOException e) {
  46.                                                 e.printStackTrace();
  47.                                         }
  48.                                         int length = re.getLength();
  49.                                         System.out.println("消息是由" + re.getAddress() + "返回的,它的端口是"
  50.                                                         + re.getPort() + "，输出的内容是"
  51.                                                         + new String(b, 0, length));
  52.                                 }
  53.                         }
  54.                 }).start();
  55.                 // set.close();// 用了线程 就没必要存在了
  56.         }
  57. }
复制代码




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