Java使用多线程，UPD通过控制台之间互相通讯

废话就不多说了，直接上demo，使用带来来进行了解

public class TaleTeceive implements  Runnable {DatagramSocket datagramSocket = null;private String msgFrom;public TaleTeceive(int formPort,String msgFrom) throws SocketException {this.datagramSocket = new DatagramSocket(formPort);this.msgFrom = msgFrom;}@Overridepublic void run() {try{//准备接收的包裹byte [] bytes = new byte[1024];while (true){DatagramPacket datagramPacket = new DatagramPacket(bytes,0,bytes.length);datagramSocket.receive(datagramPacket);//断开连接byte [] data = datagramPacket.getData();String  date = new String(data,0,data.length);System.out.println(msgFrom+":"+date);if(date.trim().startsWith("bye")){break;}}}catch (Exception e){e.printStackTrace();}finally {if(datagramSocket != null)datagramSocket.close();}}
}

public class TalkSend implements Runnable {DatagramSocket datagramSocket = null;BufferedReader bufferedReader = null ;private int formPort;private String toIP;private int toPort;public TalkSend(int formPort,String toIP,int toPort) throws SocketException {this.datagramSocket =  new DatagramSocket(this.formPort);this.bufferedReader =  new BufferedReader(new InputStreamReader(System.in));this.formPort = formPort;this.toIP = toIP;this.toPort = toPort;}@Overridepublic void run() {try{while (true){String data  = bufferedReader.readLine();byte [] dates = data.getBytes();DatagramPacket datagramPacket =  new DatagramPacket(dates,0,data.length(),new InetSocketAddress(this.toIP,this.toPort));datagramSocket.send(datagramPacket);if(data.toString().startsWith("bye")){break;}}}catch (Exception e){e.printStackTrace();}finally {try {if( bufferedReader != null)bufferedReader.close();} catch (IOException e) {e.printStackTrace();}if(datagramSocket != null)datagramSocket.close();}}
}

接下来就是创建线程了

public class TalkStudent {public static void main(String[] args) throws SocketException {new Thread(new TalkSend(7777,"127.0.0.1",9999)).start();new Thread(new TaleTeceive(8888,"老师")).start();}
}

 public class TalkTeacher {public static void main(String[] args) throws SocketException {new Thread(new TalkSend(5555,"127.0.0.1",8888)).start();new Thread(new TaleTeceive(9999,"学生")).start();}}

Java使用多线程，UPD通过控制台之间互相通讯相关推荐

java多线程有几种实现方法_Java多线程之间实现通讯
一.课程目标多线程之间如何通讯 wait.notify.notifyAll()方法 lock 停止线程守护线程 Join方法优先级 Yield 二.多线程之间如何实现通讯 2.1 什么是多线程之 ...
多线程Synchronized锁的使用与线程之间的通讯
多线程Synchronized锁的使用与线程之间的通讯一.什么是线程安全问题二.如何解决线程安全问题三.synchronized锁的基本用法 1.修饰代码块(this锁) 2.修饰实例方法(th ...
java面试题成都_成都汇智动力-java面试——多线程面试题
原标题:成都汇智动力-java面试--多线程面试题 1.多线程有什么用?发挥多核CPU的优势防止阻塞便于建模 2.创建线程的方式继承Thread类实现Runnable接口至于哪个好,不用说肯定 ...
java redis多线程爬取国美商品信息
前面那篇爬虫文章用的是单线程没有用到其它一些比较提高效率的工具比较遗憾,所以今天做了一个比较全面的爬虫.首先谢谢 @[天不生我万古长](https://www.jianshu.com/u/e34019 ...
Java计算两个字符串日期之间的天数差
Java计算两个字符串日期之间的天数差调用方法: public static void main(String[] args) throws ParseException {String a = & ...
Java 并发/多线程教程(四)-并发模型
本系列译自jakob jenkov的Java并发多线程教程(本章节部分内容参考http://ifeve.com/并发编程模型),个人觉得很有收获.由于个人水平有限,不对之处还望矫正! 并发系统可以有多 ...
java 之多线程
1.多线程:概念:1 进程:正在运行的程序2 线程:进程中一个程序执行的控制单元(执行路径).P.S.1.一个进程中可以有多个执行路径,称之为多线程.2.一个进程中至少要有一个线程.3.开启多个线程是 ...
跟着刚哥梳理java知识点——多线程（十六）
创建多线程第一种方式: ① 继承:继承Thread. ② 重写:重写Thread类的run()方法 ③ 创建:创建一个子类的对象 ④ 调用:调用线程的start()方法,启动此线程,调用run()方 ...
Java中多线程访问冲突的解决方式
Java中多线程访问冲突的解决方式当时用多线程访问同一个资源时,非常容易出现线程安全的问题,例如当多个线程同时对一个数据进行修改时,会导致某些线程对数据的修改丢失.因此需要采用同步机制来解决这种问题 ...
java并发多线程面试_Java多线程并发面试问答
java并发多线程面试 Today we will go through Java Multithreading Interview Questions and Answers. We will al ...

Java使用多线程，UPD通过控制台之间互相通讯

Java使用多线程，UPD通过控制台之间互相通讯相关推荐

最新文章

热门文章