多线程环境下使用 RocketMQ 遇到的一个问题

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

This topic created in 2605 days ago, the information mentioned may be changed or developed.

主线程中通过 DefaultMQPushConsumer 获取数据队列的数据存到一个非堵塞队列中，然后另外一个线程 poll 数据处理，但是运行后发现处理线程处理几条数据之后，一直只有获取数据没有执行数据了。

队列

数据

线程

poll

2 replies • 2019-03-12 14:05:37 +08:00

Malthael

Mar 12, 2019 via iPhone

贴代码

ClancyH

Mar 12, 2019

发现问题原因了，应该是处理程序挂在通过 Druid 获取数据库连接上了，对应的线程信息

"Thread-0" #10 prio=5 os_prio=0 tid=0x00007fd8d4491000 nid=0x3d0e waiting on condition [0x00007fd89f7e1000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000000d950b8e0> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
at com.alibaba.druid.pool.DruidDataSource.takeLast(DruidDataSource.java:1899)
at com.alibaba.druid.pool.DruidDataSource.getConnectionInternal(DruidDataSource.java:1460)
at com.alibaba.druid.pool.DruidDataSource.getConnectionDirect(DruidDataSource.java:1255)
at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1235)
at com.alibaba.druid.pool.DruidDataSource.getConnection(DruidDataSource.java:1225)
at com.zzx.wwl.alarm.util.DataBaseUtil.getConnection(DataBaseUtil.java:32)
at com.zzx.wwl.alarm.Start$1.run(Start.java:41)
at java.lang.Thread.run(Thread.java:748)