模拟10辆车载板卡发送数据

模拟10辆车载板卡发送数据，通信端口: 11111

链接：https://pan.baidu.com/s/1ZhjMZ4FmNtGJo0CItCHltw
提取码：nkz7
复制这段内容后打开百度网盘手机App，操作更方便哦

import java.io.IOException;
import java.net.InetAddress;

public class UDP_Client {  

    public static void main(String args[])throws IOException, InterruptedException{
    InetAddress loc = InetAddress.getLocalHost();
                Thread thread[] = new Thread[100];
                for(int i = 0; i < 10; i++){
                    TestRunnable testRunnable = new TestRunnable();
                    testRunnable.setTries(i);
                    testRunnable.setLoc(loc);
                    thread[i] = new Thread(testRunnable);
                    thread[i].start();
                }

    }
}

import java.net.DatagramPacket;
import java.net.DatagramSocket;
import java.net.InetAddress;
import java.text.DecimalFormat;

public class TestRunnable implements Runnable {

        int tries = 0;                            //重发数据的次数
        public void setTries(int tries) {
            this.tries = tries;
        }
        InetAddress loc;
        public void setLoc(InetAddress loc) {
            this.loc = loc;
        }
        private static final int TIMEOUT = 5000;  //设置接收数据的超时时间
        DatagramSocket ds = null;

        int test_nums = 0;
        int ProtoCnt = 0;
        DecimalFormat df=new DecimalFormat("0000");
      //数据发向本地7777端口
      //客户端在9000端口监听接收到的数据
        public void run() {
            try {

                ds = new DatagramSocket(8000 + tries);
                ds.setSoTimeout(TIMEOUT);              //设置接收数据时阻塞的最长时间
                while(true){
                    if(200 == test_nums){
                        test_nums = 0;
                    } else {
                        test_nums++;
                    }
                    String str_end = "Try cnt "+tries + ", Processors " + Runtime.getRuntime().availableProcessors()+"\r\n";
                    System.out.println(str_end);
                    if(0 == test_nums % 2){
                        ProtoCnt++;
                    }
                    String df_ProtoCnt=df.format(ProtoCnt);
                    String df_tries=df.format(tries);
                    String textdata = "test data message is sending...";
                    //监控板状态信息 begin
                   //System.out.println(socketmib.toString());
                   //String str_end=socketmib.toString();
                    //DatagramPacket dp_end =new DatagramPacket(socketmib.toByteArray(),socketmib.toByteArray().length,loc,11111);
                    DatagramPacket dp_end =new DatagramPacket(textdata.getBytes(),textdata.length(),InetAddress.getByName("10.18.60.172"),11111);
                    ds.send(dp_end);
                    Thread.sleep(500);
                }
                //tries=0;
            } catch (Exception e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            } finally {
                ds.close();
            }

        }
}

原文地址：https://blog.51cto.com/zhaoanan/2400035