java 多线程实现在线咨询(udp)

 更新时间:2020年11月21日 09:01:34   作者:Hateyes  
这篇文章主要介绍了java 多线程实现在线咨询(udp)的示例,帮助大家更好的理解和学习Java 网络编程的相关内容,感兴趣的朋友可以了解下

在线咨询:两个人都可以是发送方,也可以是接收方,实现网上在线咨询正常通信。

聊天发送线程

package chat;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetSocketAddress;
import java.net.SocketException;

/**
 * 聊天发送线程:
 * 重写 run 方法通过 implements 关键字实现 Runnable 接口
 * 重写方法快捷键:Ctrl + O
 */
public class TalkSend implements Runnable {

 DatagramSocket socket = null;
 BufferedReader reader = null;

 private int fromPort; //从哪个端口
 private String toIP; //到哪个地址
 private int toPort; //到哪个端口

 //构造:Alt + Insert
 public TalkSend(int fromPort, String toIP, int toPort) {
  this.fromPort = fromPort;
  this.toIP = toIP;
  this.toPort = toPort;

  //快捷键:Ctrl + Alt + T
  try {
   //构造一个数据报套接字并将其绑定到本地主机上的指定端口
   socket = new DatagramSocket(fromPort);

   //准备数据:控制台读取:System.in
   reader = new BufferedReader(new InputStreamReader(System.in));
  } catch (SocketException e) {
   e.printStackTrace();
  }
 }

 @Override
 public void run() {

  while (true){
   try {
    String data = reader.readLine();
    byte[] dataBytes = data.getBytes();
    DatagramPacket packet = new DatagramPacket(dataBytes, 0 , dataBytes.length, new InetSocketAddress(this.toIP, this.toPort));

    //发送数据包
    socket.send(packet);

    //当发送一句 bye 的时候表示结束发送
    if (data.equals("bye")){
     break;
    }
   } catch (IOException e) {
    e.printStackTrace();
   }
  }

  //关闭
  socket.close();

 }
}

聊天接收线程

package chat;

import java.io.IOException;
import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.SocketException;

/**
 * 聊天接收线程:
 * 重写 run 方法通过 implements 关键字实现 Runnable 接口
 * 重写方法快捷键:Ctrl + O
 */
public class TalkReceive implements Runnable {

 DatagramSocket socket = null;

 private int port;
 private String msgFrom;

 //构造
 public TalkReceive(int port, String msgFrom) {
  this.port = port;
  this.msgFrom = msgFrom;

  try {
   socket = new DatagramSocket(port);
  } catch (SocketException e) {
   e.printStackTrace();
  }
 }

 @Override
 public void run() {

  while (true){
   try {
    //准备接收数据包
    byte[] container = new byte[1024];
    DatagramPacket packet = new DatagramPacket(container, 0, container.length);

    //接收数据包
    socket.receive(packet); //阻塞式接收包裹

    //读取数据
    byte[] data = packet.getData();

    String receiveData = new String(data, 0, data.length);

    //接收到的数据
    System.out.println(msgFrom + ":" + receiveData);

    //当我们说一声 bye 的时候就表示断开连接
    if (receiveData.equals("bye")){
     break;
    }
   } catch (IOException e) {
    e.printStackTrace();
   }
  }

  //关闭
  socket.close();

 }
}

学生端

package chat;

/**
 * 学生端
 */
public class TalkStudent {

 public static void main(String[] args) {

  /**
   * 学生端
   * 从 7777 端口发送消息
   * 发送消息到 9999 端口
   * 从 8888 端口接收消息
   *
   * 开启两个线程:
   * new TalkSend:从 77777 端口发送,发送到 localhost,发送给 9999 端口
   * @param fromPort
   * @param toIP
   * @param toPort
   *
   * new TalkReceive:从 8888 端口接收,接收来自 “老师” 的消息
   * @param port
   * @param msgFrom
   *
   * 使用了一种模式:静态代理模式
   */
  new Thread(new TalkSend(7777, "localhost", 9999)).start();
  new Thread(new TalkReceive(8888, "老师")).start();
 }

}

老师端

package chat;

/**
 * 老师端
 */
public class TalkTeacher {

 public static void main(String[] args) {

  /**
   * 老师端
   * 从 5555 端口发送消息
   * 发送消息到 8888 端口
   * 从 9999 端口接收消息
   *
   * 开启两个线程:
   * new TalkSend:从 5555 端口发送,发送到 localhost,发送给 8888 端口
   * @param fromPort
   * @param toIP
   * @param toPort
   *
   * new TalkReceive:从 9999 端口接收,接收来自 “学生” 的消息
   * @param port
   * @param msgFrom
   *
   * 使用了一种模式:静态代理模式
   */
  new Thread(new TalkSend(5555, "localhost", 8888)).start();
  new Thread(new TalkReceive(9999, "学生")).start();
 }

}

效果一览

以上就是java实现的多线程实现在线咨询(udp)的详细内容,更多关于java 在线咨询的资料请关注脚本之家其它相关文章!

相关文章

  • 详解Idea 2019.2 安装lombok插件失效问题解决

    详解Idea 2019.2 安装lombok插件失效问题解决

    这篇文章主要介绍了详解Idea 2019.2 安装lombok插件失效问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2019-10-10
  • Java基于Tcp/ip连接的多人交互聊天室

    Java基于Tcp/ip连接的多人交互聊天室

    这篇文章主要为大家详细介绍了Java基于Tcp/ip连接的多人交互聊天室,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2018-07-07
  • Redis 集成Spring的示例代码(spring-data-redis)

    Redis 集成Spring的示例代码(spring-data-redis)

    本篇文章主要介绍了Redis 集成Spring的示例代码(spring-data-redis) ,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2017-09-09
  • 详解java Collections.sort的两种用法

    详解java Collections.sort的两种用法

    这篇文章主要介绍了详解java Collections.sort的两种用法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-07-07
  • Java中Date,Calendar,Timestamp的区别以及相互转换与使用

    Java中Date,Calendar,Timestamp的区别以及相互转换与使用

    以下是对Java中Date,Calendar,Timestamp的区别以及相互转换与使用进行了详细的介绍,需要的朋友可以过来参考下
    2013-09-09
  • Java集合框架Collections原理及用法实例

    Java集合框架Collections原理及用法实例

    这篇文章主要介绍了Java集合框架Collections原理及用法实例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-08-08
  • Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 代码实践

    Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 代码实

    这篇文章主要介绍了Spring Cloud Feign 自定义配置(重试、拦截与错误码处理) 实践,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友可以参考下
    2020-08-08
  • Java的反射机制---动态调用对象的简单方法

    Java的反射机制---动态调用对象的简单方法

    下面小编就为大家带来一篇Java的反射机制---动态调用对象的简单方法。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-07-07
  • java LRU算法介绍与用法示例

    java LRU算法介绍与用法示例

    这篇文章主要介绍了java LRU算法,简单介绍了LRU算法的概念并结合实例形式分析了LRU算法的具体使用方法,需要的朋友可以参考下
    2017-09-09
  • 详解Spring中bean的几种注入方式

    详解Spring中bean的几种注入方式

    这篇文章主要介绍了详解Spring中bean的几种注入方式,主要介绍了4种注入,主要有属性注入、构造函数注入、工厂方法注入,非常具有实用价值,需要的朋友可以参考下
    2018-06-06

最新评论