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

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

聊天发送线程

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;


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;


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) {

  
  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) {

  
  new Thread(new TalkSend(5555, "localhost", 8888)).start();
  new Thread(new TalkReceive(9999, "学生")).start();
 }

}

效果一览

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