【发布时间】:2016-01-20 11:09:19
【问题描述】:
我在一家为我们的客户提供实时车辆定位网站的公司工作。客户车辆每秒发送 1 个 TCP 数据包,其中包含有关车辆的所有信息(电池电压、速度、RPM、车门状态、DTC、燃油油位、油耗等)。我们的客户有 5 到 10 辆车,有些客户有 30 到 50 辆车。
在服务器端,我们有一个 java 应用程序,它从 TCP 套接字接收这些信息并将它们解码并写入数据库。在代码中,在我之前编写它的人使用了数据库池(BasicDataSource)。它的制作方式是,当收到一个数据包时,会为数据包创建一个线程,对数据包进行解码并将信息写入线程内的数据库,然后关闭数据库连接。处理完一个数据包后,线程结束。有时我们每秒收到太多数据包,以至于应用程序创建了 100 到 200 个与数据库的连接。
我是一名 C++ 程序员,我知道如何用 java 编程,但我不是专家,所以我想知道这样做是否真的是个好主意。我想做的方式是我有一个 FIFO,有数据生产者和数据消费者,数据生产者填充 FIFO,数据消费者清空 FIFO。我在想的是创建一个连接并保持打开状态并不断写入我的数据,因为我(当我们将所有车辆数据包相加时)每秒至少有 80 到 100 个数据包,所以我真的不需要关闭它,因为我将只有两个线程,生产者和消费者。 (所以我每次清空 FIFO 时都会在消费者内部写入)
我在互联网上搜索,我在很多地方发现我想要的方式不是一个好方法。但我不知道什么最适合我们的情况,我想消除创建太多线程和创建太多与数据库的连接。 java 和数据库专家如何看待我可以改进此应用程序的方式。
(我在文章开头谈到的网站是一个外部服务器,它连接到这个数据库并获取最后写入数据库的数据并将它们显示到HereMap地图中。所以系统的实时部分真的是重要)
这里是与同一应用程序相关的另一个问题的 URL(针对某些性能问题)How to improve a Java application working with BasicDataSource object?
【问题讨论】:
-
这真的是一个网站,还是你在监听一个守护进程或类似的 TCP 端口?
-
@NevilleK 是的,你是对的,我忘了说这部分,它是一个网站,它读取最后写入数据库的数据并将其显示在网站中
-
“线程太多” - 真的吗?几百个线程就好了。几千应该没问题。你真的有一个可量化的、可重现的问题,还是你只是不喜欢这个设计?
-
这里是我用应用程序做的测试的链接,你可以看到应用程序有很多性能问题stackoverflow.com/q/33129860/5420624
-
@NevilleK 我认为数百个线程是 fin,数千个,但是应用程序创建线程并且它们只运行几毫秒。这意味着应用程序每秒创建 100 个线程。我不是 Java 专家,但在 C++ 中创建线程需要花费大量时间并破坏它,所以经常创建线程不是一个好主意。
标签: java database multithreading server real-time