2

我看到的大多数 RxJava 示例都与网络调用有关。我是这个框架的新手，所以我想知道将它用于并行文件解析之类的东西是否也有意义。我有一个文件目录，我需要将其数据解析为 SQL 表。我可以用 RxJava 做到这一点吗？我希望它尽可能多线程以提高效率。

数据说明

我的数据有一个以一堆Sections开头的层次结构。每个Section包含一个或多个Subsection。每个小节包含一个或多个HTML文件。

SQL 表

sqlite> SELECT * FROM sections;
_id         ordinal     title     
----------  ----------  ----------
1           1           Management
2           2           Emergency Preparedness

--有一个引用sections 表的外键

sqlite> SELECT * FROM subsections;
_id         ordinal     chapter_id  title     
----------  ----------  ----------  ----------
1           A           1           General   
2           B           1           Resources

--具有引用部分和子部分表的外键

sqlite> SELECT * FROM html;
_id         chapter_id  subsection_id   number      html_filename             
----------  ----------  ----------  ----------  --------------
1           1           1           1           /1a-1.html
2           1           1           2           /1a-2.html
3           1           1           3           /1a-3.html
4           1           1           4           /1a-4.html
5           1           2           1           /1b-1.html
6           2           2           1           /2a-1.html
7           2           2           2           /2a-2.html
8           2           2           1           /2b-1.html

_id字段是一个自动递增的主键（这不会每次都匹配序数）。subsections表依赖于接收其相关部分的主键。这意味着一旦插入第 1节，就可以插入第1a、1b、1c等节（但不能插入2a）

目录结构

      //Section 1
/1.title
      //Subsection A
/1a.title
      //html files for 1a
/1a-1.html
/1a-2.html
      //Subsection B
/1b.title
      //html files for 1b
/1b-1.html
/1b-2.html
      //Section 2
/2.title
/2a.title
      //..etc

每个 SQL 插入都可以使用 java builder 类构建，对于/1b-2.html ，它看起来像这样

db.insert(HTML_TABLE, null, new HTML.Builder()
                .chapterId(section1)
                .letterId(subsectionB)
                .number(2)
                .build());

我最终将有大约 50-60 个部分，但是整个部分的每个 SQL 插入、其子部分和它们的 HTML 文件都可以并行插入。使用 RxJava 对这样的事情有意义吗？

4

1 回答 1

0

Rx（在任何平台上）不太适合大多数形式的并行处理。它处理本质上是序列化的流。听起来您正在寻找某种 ETL 工具。

于 2015-03-09T13:52:55.243 回答