专栏首页大数据分享(四)Java读写文件,合并成新的文件

(四)Java读写文件,合并成新的文件

文件一:

AppCrashed participate__recharge_activity participate_activity

AppClickAppViewScreen WebClickWebStay PlanMsgSendPrepare PlanConverted AppEnd

文件二:

App 崩溃 参与充值活动 参与活跃活动 App 元素点击 App 浏览页面 Web 元素点击 Web 视区停留 Web 浏览页面 同时在线人数(特殊心跳事件) 拍卖行交易买入 装备升级 好感度培养 道具商店点击 卡牌抽取 分享 剧情 钻石商店点击 PVP战斗 关卡PVE战斗 道具商店提交订单 道具商店支付订单 神魄升级(属性系统) 新手引导通过 角色升级 登录游戏 创建角色 道具产出 道具消耗 订单提交【钻石礼包】 订单购买【钻石礼包】 卡牌升级 完成日常任务 Push 点击 App 激活 注册账号 登陆账号 消息已准备 消息已发送 推送转化 App启动 $退出APP

文件读取工具:

package xxxx.com.test.file_acc; import java.io.*;

public class FileUtils { public static void readToBuffer(StringBuffer buffer,String filePath) throws IOException { InputStream is = new FileInputStream(filePath); BufferedReader reader = new BufferedReader(new InputStreamReader(is)); String line = reader.readLine(); while (line != null){ // line为空说明读完了 // 将读到的内容添加到buffer中 buffer.append(line); buffer.append("\n"); // 读取下一行 line = reader.readLine(); } reader.close(); is.close(); }

public static String readFile(String filePath) throws IOException {
    StringBuffer sb = new StringBuffer();
    // 传入buffer和文件路径
    FileUtils.readToBuffer(sb,filePath);
    return sb.toString();
}

}

文件合并,执行:

package xxxx.com.test.file_acc; import java.io.*;

public class File_append { public static void main(String[] args) throws IOException { String filePath01 = "F:\Project\WordCount\src\main\java\xxxx\com\test\file_acc\file01"; String readFile01 = FileUtils.readFile(filePath01); String filePath02 = "F:\Project\WordCount\src\main\java\xxxx\com\test\file_acc\file02"; String readFile02 = FileUtils.readFile(filePath02);

    System.out.println(readFile01);
    System.out.println("\n-------------------\n");
    System.out.println(readFile02);
    System.out.println("\n-------------------\n");
    // 进行文件合并
    mergeFiles(readFile01,readFile02);

    String file03 = "F:\\Project\\WordCount\\file03.txt";
    String read = FileUtils.readFile(file03);
    System.out.println(read);
}


public static void mergeFiles(String br1, String br2) throws IOException {
    // 写入的路径
    PrintWriter pw = new PrintWriter("file03.txt");

    // 用数组将读取的数据进行切分
    String[] split1 = br1.split("\n");
    String[] split2 = br2.split("\n");
    for (int i = 0; i < split1.length; i++) {
        // 开始将两个文件的数据写入到一起
        pw.println(split1[i]+"\t"+split2[i]);
        // 每行刷新
        pw.flush();
    }
    pw.close();
}

}

输出结果:

AppCrashed App 崩溃 participate__recharge_activity 参与充值活动 participate_activity 参与活跃活动

AppViewScreen App 浏览页面

WebStay Web 视区停留

PlanMsgSendPrepare 消息已准备

PlanConverted 推送转化

AppEnd $退出APP

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

我来说两句

0 条评论
登录 后参与评论

相关文章

  • (八)kafka安装搭建

    Kafka集群部署 1)解压安装包 tar -zxvf kafka_2.11-0.11.0.0.tgz -C /opt/module/ 2)修改解压后的文...

    wolf
  • (五)Hive的UDF、UDAF和UDTF自定义函数

    order by(全局排序):不经常用 sort by+distrbutre by :经常用

    wolf
  • html基础

    <head> 元素包含了文档的元(meta)数据,如 <meta charset="utf-8"> 定义网页编码格式为 utf-8。

    wolf
  • Java 中 String 类为什么要设计成不可变的?

    String 是 Java 中不可变的类,所以一旦被实例化就无法修改。不可变类的实例一旦创建,其成员变量的值就不能被修改。本文总结下 String 类设计成不可...

    用户3596197
  • java实现Kafka生产者Producer工具类

    天策
  • Map排序

    Map排序的方式有很多种,这里记录下自己总结的两种比较常用的方式:按键排序(sort by key), 按值排序(sort by value)。 按键排序(...

    xiangzhihong
  • Spark Tips3: 在Spark Streaming job中读取Kafka messages及其offsetRange

    在Spark Streaming job中读取Kafka topic(s)中的messages时,有时我们会需要同步记录下每次读取的messages的offse...

    叶锦鲤
  • httpclient 爬虫实例——爬取三级中学名

    本人在使用 httpclient 的过程中,突然想起来可以爬取一些数据,比如全国的中学名。当然不是空穴来风,之前也做过这方面的爬虫,不过基于selenium 做...

    FunTester
  • Spring Cloud实战小贴士:Zuul处理Cookie和重定向

    由于我们在之前所有的入门教程中,对于HTTP请求都采用了简单的接口实现。而实际使用过程中,我们的HTTP请求要复杂的多,比如当我们将Spring Cloud Z...

    程序猿DD
  • API接口设计规范

    说明:在实际的业务中,难免会跟第三方系统进行数据的交互与传递,那么如何保证数据在传输过程中的安全呢(防窃取)?除了https的协议之外,能不能加上通用的一套算法...

    Java旅途

扫码关注云+社区

领取腾讯云代金券