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

V2EX = way to explore

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

现在注册

已注册用户请登录

这是一个创建于 2113 天前的主题，其中的信息可能已经有所发展或是发生改变。

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

队列

数据

线程

poll

2 条回复 • 2019-03-12 14:05:37 +08:00

Malthael

2019-03-12 12:58:10 +08:00 via iPhone

贴代码

ClancyH

2019-03-12 14:05:37 +08:00

发现问题原因了，应该是处理程序挂在通过 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)