欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

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

程序员文章站 2022-09-17 15:22:21
在线咨询:两个人都可以是发送方,也可以是接收方,实现网上在线咨询正常通信。聊天发送线程package chat;import java.io.bufferedreader;import java.io...

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

聊天发送线程

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 多线程实现在线咨询(udp)

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