UDP實(shí)現(xiàn)多線程通信

//接收進(jìn)程

import java.io.IOException;

import java.net.DatagramPacket;

import java.net.DatagramSocket;

import java.net.ServerSocket;

public class UDPrecive implements Runnable {

int port;

String name;

DatagramSocket socket=null;

DatagramPacket packet=null;

public UDPrecive(int port, String name) {

this.port = port;

this.name = name;

try {

socket = new DatagramSocket(this.port);

} catch (IOException e) {

e.printStackTrace();

}

}

@Override

public void run() {

while (true) {

try {

byte[] bytes = new byte[1024];

packet = new DatagramPacket(bytes,0, bytes.length);

socket.receive(packet);

String msg= new String(packet.getData(),0,bytes.length);

System.out.println(name+":"+msg);

if (msg.equals("bye")){

break;

}

} catch (IOException e) {

e.printStackTrace();

}

}

socket.close();

}

}

//發(fā)送進(jìn)程

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 UDPclient implements Runnable {

int toPort;

String toIP;

DatagramSocket socket=null;

DatagramPacket packet=null;

BufferedReader reader=null;

public UDPclient(int toPort,String toIP) {

this.toIP = toIP;

this.toPort=toPort;

reader = new BufferedReader(new InputStreamReader(System.in));

try {

socket = new DatagramSocket();

} catch (SocketException e) {

e.printStackTrace();

}

}

@Override

public void run() {

while (true) {

try {

String s = reader.readLine();

byte[] bytes = s.getBytes();

packet=new DatagramPacket(bytes,0,bytes.length,new InetSocketAddress(this.toIP,this.toPort));

socket.send(packet);

if (s.equals("bye")){

break;

}

} catch (IOException e) {

e.printStackTrace();

}

}

try {

reader.close();

} catch (IOException e) {

e.printStackTrace();

}

socket.close();

}

}

//學(xué)生端

public class Student {

public static void main(String[] args) {

new Thread(new UDPrecive(7777,"老師")).start();

new Thread(new UDPclient(6666,"localhost")).start();

}

}

//老師端

public class Teacher {

public static void main(String[] args) {

new Thread(new UDPrecive(6666,"學(xué)生")).start();

new Thread(new UDPclient(7777,"localhost")).start();

}

}

效果：

總結(jié)

以上是生活随笔為你收集整理的udp多线程 java_UDP实现多线程通信的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。