devbox
我家自动化
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

日志项目之——将kafka数据存入hbase中_flink如何将kafka的json格式主题写入hbase

作者：我家自动化 | 2024-06-23 14:40:26

赞

踩

flink如何将kafka的json格式主题写入hbase

目录

1.添加依赖

2.在hbase shell界面中分别输入下面的语句，创建namespace和表

3.UserFriendToHB

4.UsersToHB

5.TrainToHB

6.EventsToHB

7.EventAttendeToHb

1.添加依赖

  1. <dependencies>
  2.     <dependency>
  3.       <groupId>junit</groupId>
  4.       <artifactId>junit</artifactId>
  5.       <version>4.11</version>
  6.       <scope>test</scope>
  7.     </dependency>
  8.     <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka-clients -->
  9.     <dependency>
  10.       <groupId>org.apache.kafka</groupId>
  11.       <artifactId>kafka-clients</artifactId>
  12.       <version>2.8.0</version>
  13.     </dependency>
  14.     <!-- https://mvnrepository.com/artifact/org.apache.kafka/kafka -->
  15.     <dependency>
  16.       <groupId>org.apache.kafka</groupId>
  17.       <artifactId>kafka_2.12</artifactId>
  18.       <version>2.8.0</version>
  19.     </dependency>
  20.     <dependency>
  21.       <groupId>org.apache.kafka</groupId>
  22.       <artifactId>kafka-streams</artifactId>
  23.       <version>2.8.0</version>
  24.     </dependency>
  25.     <!--hbase相关依赖-->
  26.     <dependency>
  27.       <groupId>org.apache.hbase</groupId>
  28.       <artifactId>hbase-client</artifactId>
  29.       <version>2.3.5</version>
  30.     </dependency>
  31.     <dependency>
  32.       <groupId>org.apache.hbase</groupId>
  33.       <artifactId>hbase-server</artifactId>
  34.       <version>2.3.5</version>
  35.     </dependency>
  36.   </dependencies>

2.在hbase shell界面中分别输入下面的语句，创建namespace和表

  1. create_namespace 'events_db'
  2.  
  3. create 'events_db:users','profile','region','registration'
  4.  
  5. create 'events_db:user_friend','uf'
  6.  
  7. create 'events_db:events','schedule','location','creator','remark'
  8.  
  9. create 'events_db:event_attendee','euat'
  10.  
  11. create 'events_db:train','eu'

3.UserFriendToHB

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HConstants;
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Put;
  8. import org.apache.hadoop.hbase.client.Table;
  9. import org.apache.hadoop.hbase.util.Bytes;
  10. import org.apache.kafka.clients.consumer.ConsumerConfig;
  11. import org.apache.kafka.clients.consumer.ConsumerRecord;
  12. import org.apache.kafka.clients.consumer.ConsumerRecords;
  13. import org.apache.kafka.clients.consumer.KafkaConsumer;
  14. import org.apache.kafka.common.serialization.StringDeserializer;
  15.  
  16. import java.io.IOException;
  17. import java.time.Duration;
  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Properties;
  21.  
  22. /**
  23.  * 将Kafka中的user_friends数据消费到HBase中
  24.  */
  25. public class UserFriendToHB {
  26.     static int num = 0;// 计数器
  27.  
  28.     public static void main(String[] args) {
  29.         Properties prop = new Properties();
  30.         prop.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.180.147:9092");
  31.         prop.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  32.         prop.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  33.         prop.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");// 手动提交
  34.         prop.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");// 自动提交时，提交时间
  35.         prop.put(ConsumerConfig.GROUP_ID_CONFIG, "userfriend_group");
  36.         prop.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  37.  
  38.         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
  39.         consumer.subscribe(Collections.singleton("user_friends"));
  40.  
  41.         // 配置HBase信息，连接HBase数据库
  42.         Configuration conf = HBaseConfiguration.create();
  43.         conf.set(HConstants.HBASE_DIR, "hdfs://192.168.180.147:9000/hbase");
  44.         conf.set(HConstants.ZOOKEEPER_QUORUM, "192.168.180.147");
  45.         conf.set(HConstants.CLIENT_PORT_STR, "2181");
  46.  
  47.         Connection connection = null;
  48.         try {
  49.             connection = ConnectionFactory.createConnection(conf);
  50.             Table userFriendTable = connection.getTable(TableName.valueOf("events_db:user_friend"));
  51.             while (true) {
  52.                 ConsumerRecords<String, String> poll = consumer.poll(Duration.ofMillis(100));
  53.                 ArrayList<Put> datas = new ArrayList<>();
  54.                 for (ConsumerRecord<String, String> record :
  55.                         poll) {
  56.                     System.out.println(record.value());// userid,friendid
  57.                     String[] split = record.value().split(",");
  58.                     Put put = new Put(Bytes.toBytes(((split[0]) + split[1]).hashCode()));
  59.                     put.addColumn("uf".getBytes(), "user_id".getBytes(), split[0].getBytes());
  60.                     put.addColumn("uf".getBytes(), "friend_id".getBytes(), split[1].getBytes());
  61.                     datas.add(put);
  62.                 }
  63.                 num = num + datas.size();
  64.                 System.out.println("---------------------------------num:" + num);
  65.                 if (datas.size() != 0)
  66.                     userFriendTable.put(datas);
  67.                 try {
  68.                     Thread.sleep(10);
  69.                 } catch (InterruptedException e) {
  70.                     e.printStackTrace();
  71.                 }
  72.             }
  73.         } catch (IOException e) {
  74.             e.printStackTrace();
  75.         }
  76.     }
  77. }

4.UsersToHB

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HConstants;
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Put;
  8. import org.apache.hadoop.hbase.client.Table;
  9. import org.apache.hadoop.hbase.util.Bytes;
  10. import org.apache.kafka.clients.consumer.ConsumerConfig;
  11. import org.apache.kafka.clients.consumer.ConsumerRecord;
  12. import org.apache.kafka.clients.consumer.ConsumerRecords;
  13. import org.apache.kafka.clients.consumer.KafkaConsumer;
  14. import org.apache.kafka.common.serialization.StringDeserializer;
  15.  
  16. import java.io.IOException;
  17. import java.time.Duration;
  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Properties;
  21.  
  22. public class UsersToHB {
  23.     static int num = 0;// 计数器
  24.  
  25.     public static void main(String[] args) {
  26.         Properties prop = new Properties();
  27.         prop.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.180.147:9092");
  28.         prop.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  29.         prop.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  30.         prop.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");// 手动提交
  31.         prop.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");// 自动提交时，提交时间
  32.         prop.put(ConsumerConfig.GROUP_ID_CONFIG, "users_group");
  33.         prop.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  34.         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
  35.         consumer.subscribe(Collections.singleton("users"));
  36.  
  37.         // 配置HBase信息，连接HBase数据库
  38.         Configuration conf = HBaseConfiguration.create();
  39.         conf.set(HConstants.HBASE_DIR, "hdfs://192.168.180.147:9000/hbase");
  40.         conf.set(HConstants.ZOOKEEPER_QUORUM, "192.168.180.147");
  41.         conf.set(HConstants.CLIENT_PORT_STR, "2181");
  42.  
  43.         Connection connection = null;
  44.  
  45.         try {
  46.             connection = ConnectionFactory.createConnection(conf);
  47.             Table usersTable = connection.getTable(TableName.valueOf("events_db:users"));
  48.             while (true) {
  49.                 ConsumerRecords<String, String> poll = consumer.poll(Duration.ofMillis(100));
  50.                 ArrayList<Put> datas = new ArrayList<>();
  51.                 for (ConsumerRecord<String, String> record :
  52.                         poll) {
  53.                     System.out.println(record.value());
  54.                     String[] user = record.value().split(",");
  55.                     Put put = new Put(Bytes.toBytes(user[0]));
  56.                     put.addColumn("profile".getBytes(), "birthyear".getBytes(), user[2].getBytes());
  57.                     put.addColumn("profile".getBytes(), "gender".getBytes(), user[3].getBytes());
  58.                     put.addColumn("region".getBytes(), "locale".getBytes(), user[1].getBytes());
  59.                     if (user.length > 5)
  60.                         put.addColumn("region".getBytes(), "location".getBytes(), user[5].getBytes());
  61.                     if (user.length > 6)
  62.                         put.addColumn("region".getBytes(), "timezone".getBytes(), user[6].getBytes());
  63.                     if (user.length > 4)
  64.                         put.addColumn("registration".getBytes(), "joinedAt".getBytes(), user[4].getBytes());
  65.                     datas.add(put);
  66.                 }
  67.                 num = num + datas.size();
  68.                 System.out.println("---------------------------------num:" + num);
  69.                 if (datas.size() != 0)
  70.                     usersTable.put(datas);
  71.                 try {
  72.                     Thread.sleep(10);
  73.                 } catch (InterruptedException e) {
  74.                     e.printStackTrace();
  75.                 }
  76.             }
  77.         } catch (IOException e) {
  78.             e.printStackTrace();
  79.         }
  80.     }
  81. }

5.TrainToHB

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HConstants;
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Put;
  8. import org.apache.hadoop.hbase.client.Table;
  9. import org.apache.hadoop.hbase.util.Bytes;
  10. import org.apache.kafka.clients.consumer.ConsumerConfig;
  11. import org.apache.kafka.clients.consumer.ConsumerRecord;
  12. import org.apache.kafka.clients.consumer.ConsumerRecords;
  13. import org.apache.kafka.clients.consumer.KafkaConsumer;
  14. import org.apache.kafka.common.serialization.StringDeserializer;
  15.  
  16. import java.io.IOException;
  17. import java.time.Duration;
  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Properties;
  21.  
  22. public class TrainToHB {
  23.     static int num = 0;// 计数器
  24.  
  25.     public static void main(String[] args) {
  26.         Properties prop = new Properties();
  27.         prop.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.180.147:9092");
  28.         prop.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  29.         prop.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  30.         prop.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");// 手动提交
  31.         prop.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");// 自动提交时，提交时间
  32.         prop.put(ConsumerConfig.GROUP_ID_CONFIG, "train_group");
  33.         prop.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  34.         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
  35.         consumer.subscribe(Collections.singleton("train"));
  36.  
  37.         // 配置HBase信息，连接HBase数据库
  38.         Configuration conf = HBaseConfiguration.create();
  39.         conf.set(HConstants.HBASE_DIR, "hdfs://192.168.180.147:9000/hbase");
  40.         conf.set(HConstants.ZOOKEEPER_QUORUM, "192.168.180.147");
  41.         conf.set(HConstants.CLIENT_PORT_STR, "2181");
  42.  
  43.         Connection connection = null;
  44.  
  45.         try {
  46.             connection = ConnectionFactory.createConnection(conf);
  47.             Table trainTable = connection.getTable(TableName.valueOf("events_db:train"));
  48.             while (true) {
  49.                 ConsumerRecords<String, String> poll = consumer.poll(Duration.ofMillis(100));
  50.                 ArrayList<Put> datas = new ArrayList<>();
  51.                 for (ConsumerRecord<String, String> record :
  52.                         poll) {
  53.                     System.out.println(record.value());
  54.                     String[] train = record.value().split(",");
  55.                     double random = Math.random();
  56.                     Put put = new Put(Bytes.toBytes(train[0]+train[1]+random));
  57.                     put.addColumn("eu".getBytes(),"user".getBytes(),train[0].getBytes());
  58.                     put.addColumn("eu".getBytes(),"event".getBytes(),train[1].getBytes());
  59.                     put.addColumn("eu".getBytes(),"invited".getBytes(),train[2].getBytes());
  60.                     put.addColumn("eu".getBytes(),"timestamp".getBytes(),train[3].getBytes());
  61.                     put.addColumn("eu".getBytes(),"interested".getBytes(),train[4].getBytes());
  62.                     put.addColumn("eu".getBytes(),"not_interested".getBytes(),train[5].getBytes());
  63.  
  64.                     datas.add(put);
  65.                 }
  66.                 num = num + datas.size();
  67.                 System.out.println("---------------------------------num:" + num);
  68.                 if (datas.size() != 0)
  69.                     trainTable.put(datas);
  70.                 try {
  71.                     Thread.sleep(10);
  72.                 } catch (InterruptedException e) {
  73.                     e.printStackTrace();
  74.                 }
  75.             }
  76.         } catch (IOException e) {
  77.             e.printStackTrace();
  78.         }
  79.     }
  80. }

6.EventsToHB

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HConstants;
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Put;
  8. import org.apache.hadoop.hbase.client.Table;
  9. import org.apache.hadoop.hbase.util.Bytes;
  10. import org.apache.kafka.clients.consumer.ConsumerConfig;
  11. import org.apache.kafka.clients.consumer.ConsumerRecord;
  12. import org.apache.kafka.clients.consumer.ConsumerRecords;
  13. import org.apache.kafka.clients.consumer.KafkaConsumer;
  14. import org.apache.kafka.common.serialization.StringDeserializer;
  15.  
  16. import java.io.IOException;
  17. import java.time.Duration;
  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Properties;
  21.  
  22. public class EventsToHB {
  23.     static int num = 0;// 计数器
  24.  
  25.     public static void main(String[] args) {
  26.         Properties prop = new Properties();
  27.         prop.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.180.147:9092");
  28.         prop.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  29.         prop.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  30.         prop.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");// 手动提交
  31.         prop.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");// 自动提交时，提交时间
  32.         prop.put(ConsumerConfig.GROUP_ID_CONFIG, "events_group");
  33.         prop.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  34.         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
  35.         consumer.subscribe(Collections.singleton("events"));
  36.  
  37.         // 配置HBase信息，连接HBase数据库
  38.         Configuration conf = HBaseConfiguration.create();
  39.         conf.set(HConstants.HBASE_DIR, "hdfs://192.168.180.147:9000/hbase");
  40.         conf.set(HConstants.ZOOKEEPER_QUORUM, "192.168.180.147");
  41.         conf.set(HConstants.CLIENT_PORT_STR, "2181");
  42.  
  43.         Connection connection = null;
  44.  
  45.         try {
  46.             connection = ConnectionFactory.createConnection(conf);
  47.             Table eventsTable = connection.getTable(TableName.valueOf("events_db:events"));
  48.             while (true) {
  49.                 ConsumerRecords<String, String> poll = consumer.poll(Duration.ofMillis(100));
  50.                 ArrayList<Put> datas = new ArrayList<>();
  51.                 for (ConsumerRecord<String, String> record :
  52.                         poll) {
  53.                     System.out.println(record.value());
  54.                     String[] events = record.value().split(",");
  55.                     Put put = new Put(Bytes.toBytes((events[0])));
  56.                     put.addColumn("creator".getBytes(), "userid".getBytes(), Bytes.toBytes(events[1]));
  57.                     put.addColumn("schedule".getBytes(), "starttime".getBytes(), Bytes.toBytes(events[2]));
  58.                     put.addColumn("location".getBytes(), "city".getBytes(), Bytes.toBytes(events[3]));
  59.                     put.addColumn("location".getBytes(), "state".getBytes(), Bytes.toBytes(events[4]));
  60.                     put.addColumn("location".getBytes(), "zip".getBytes(), Bytes.toBytes(events[5]));
  61.                     put.addColumn("location".getBytes(), "country".getBytes(), Bytes.toBytes(events[6]));
  62.                     put.addColumn("location".getBytes(), "lat".getBytes(), Bytes.toBytes(events[7]));
  63.                     put.addColumn("location".getBytes(), "lng".getBytes(), Bytes.toBytes(events[8]));
  64.                     put.addColumn("remark".getBytes(), "commonwords".getBytes(), Bytes.toBytes(events[9]));
  65.  
  66.                     datas.add(put);
  67.                 }
  68.                 num = num + datas.size();
  69.                 System.out.println("---------------------------------num:" + num);
  70.                 if (datas.size() != 0)
  71.                     eventsTable.put(datas);
  72.                 try {
  73.                     Thread.sleep(10);
  74.                 } catch (InterruptedException e) {
  75.                     e.printStackTrace();
  76.                 }
  77.             }
  78.         } catch (IOException e) {
  79.             e.printStackTrace();
  80.         }
  81.     }
  82. }

7.EventAttendeToHb

  1. import org.apache.hadoop.conf.Configuration;
  2. import org.apache.hadoop.hbase.HBaseConfiguration;
  3. import org.apache.hadoop.hbase.HConstants;
  4. import org.apache.hadoop.hbase.TableName;
  5. import org.apache.hadoop.hbase.client.Connection;
  6. import org.apache.hadoop.hbase.client.ConnectionFactory;
  7. import org.apache.hadoop.hbase.client.Put;
  8. import org.apache.hadoop.hbase.client.Table;
  9. import org.apache.hadoop.hbase.util.Bytes;
  10. import org.apache.kafka.clients.consumer.ConsumerConfig;
  11. import org.apache.kafka.clients.consumer.ConsumerRecord;
  12. import org.apache.kafka.clients.consumer.ConsumerRecords;
  13. import org.apache.kafka.clients.consumer.KafkaConsumer;
  14. import org.apache.kafka.common.serialization.StringDeserializer;
  15.  
  16. import java.io.IOException;
  17. import java.time.Duration;
  18. import java.util.ArrayList;
  19. import java.util.Collections;
  20. import java.util.Properties;
  21.  
  22. public class EventAttendeToHb {
  23.     static int num = 0;// 计数器
  24.  
  25.     public static void main(String[] args) {
  26.         Properties prop = new Properties();
  27.         prop.put(ConsumerConfig.BOOTSTRAP_SERVERS_CONFIG, "192.168.180.147:9092");
  28.         prop.put(ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  29.         prop.put(ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG, StringDeserializer.class);
  30.         prop.put(ConsumerConfig.ENABLE_AUTO_COMMIT_CONFIG, "false");// 手动提交
  31.         prop.put(ConsumerConfig.AUTO_COMMIT_INTERVAL_MS_CONFIG, "1000");// 自动提交时，提交时间
  32.         prop.put(ConsumerConfig.GROUP_ID_CONFIG, "eventattendee_group");
  33.         prop.put(ConsumerConfig.AUTO_OFFSET_RESET_CONFIG, "earliest");
  34.         KafkaConsumer<String, String> consumer = new KafkaConsumer<>(prop);
  35.         consumer.subscribe(Collections.singleton("event_attendees"));
  36.  
  37.         // 配置HBase信息，连接HBase数据库
  38.         Configuration conf = HBaseConfiguration.create();
  39.         conf.set(HConstants.HBASE_DIR, "hdfs://192.168.180.147:9000/hbase");
  40.         conf.set(HConstants.ZOOKEEPER_QUORUM, "192.168.180.147");
  41.         conf.set(HConstants.CLIENT_PORT_STR, "2181");
  42.  
  43.         Connection connection = null;
  44.  
  45.         try {
  46.             connection = ConnectionFactory.createConnection(conf);
  47.             Table table = connection.getTable(TableName.valueOf("events_db:event_attendee"));
  48.             while (true) {
  49.                 ConsumerRecords<String, String> poll = consumer.poll(Duration.ofMillis(100));
  50.                 ArrayList<Put> datas = new ArrayList<>();
  51.                 for (ConsumerRecord<String, String> record :
  52.                         poll) {
  53.                     System.out.println(record.value());// eventid,friendid,yes/no/maybe
  54.                     String[] eventattend = record.value().split(",");
  55.                     Put put = new Put(Bytes.toBytes((eventattend[0]+eventattend[1]+eventattend[2])));
  56.                     put.addColumn("euat".getBytes(),"eventid".getBytes(),Bytes.toBytes(eventattend[0]));
  57.                     put.addColumn("euat".getBytes(),"friendid".getBytes(),Bytes.toBytes(eventattend[1]));
  58.                     put.addColumn("euat".getBytes(),"state".getBytes(),Bytes.toBytes(eventattend[2]));
  59.  
  60.                     datas.add(put);
  61.                 }
  62.                 num = num + datas.size();
  63.                 System.out.println("---------------------------------num:" + num);
  64.                 if (datas.size() != 0)
  65.                     table.put(datas);
  66.                 try {
  67.                     Thread.sleep(10);
  68.                 } catch (InterruptedException e) {
  69.                     e.printStackTrace();
  70.                 }
  71.             }
  72.         } catch (IOException e) {
  73.             e.printStackTrace();
  74.         }
  75.     }
  76. }

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/我家自动化/article/detail/749860
推荐阅读
相关标签

Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

  

闽ICP备14008679号