流程设计器配置,rocketmq发消息超时报错

利江 错误处理 62

版本号:

镜像版本 harbor.oinone.top/oinone/oinone-designer-mini-v5.2:5.2.5.1

本地版本 5.2.5

错误信息:

io.netty.channel.ConnectTimeoutException: connection timed out: /172.16.20.126:10911
at io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe$1.run(AbstractNioChannel.java:261) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.PromiseTask.runTask(PromiseTask.java:98) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.ScheduledFutureTask.run(ScheduledFutureTask.java:170) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute$$$capture(AbstractEventExecutor.java:164) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.AbstractEventExecutor.safeExecute(AbstractEventExecutor.java) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor.runAllTasks(SingleThreadEventExecutor.java:472) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:500) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[netty-all-4.1.58.Final.jar:4.1.58.Final]
at java.lang.Thread.run(Thread.java:750) ~[na:1.8.0_421]

2024-10-31 09:36:55.830 ERROR 468 --- [ sql.record] p.s.p.f.c.e.rocketmq.RocketMQTemplate : syncSendOrderly failed. destination:CHANGE_DATA_EVENT_TOPIC, message:GenericMessage [payload=Row{eventType=INSERT, schema='biz', table='simple_ex_home_sales', id=670537496911875082, pkNames=[], sql='null', before=[], after=[Column{name='area', value=杭州, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='writeUid', value=10001, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='productNum', value=6, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='id', value=670537496911875082, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='META_BIT', value=0, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}, Column{name='createUid', value=10001, isUpdate=false, isNull=false, isKey=false, ltype='null', stype='null'}], changeDate=null, env='null', tenant='', destination='null', executeTime=null, deloyTime=1730301065000}, headers={keys=null, topic=CHANGE_DATA_EVENT_TOPIC, tag=INSERT, id=e376bf63-c07a-7a48-e432-19a7fde738b2, PAMIRS_SESSION_KEY={"TRANSMITTABLE_EXTEND":"{}","KERNEL_EXTEND":"{}","REQUEST_VARIABLES":"pro.shushi.pamirs.meta.api.dto.protocol.PamirsRequestVariables#{\"requestInfoMap\":{\"checkStrategy\":\"RETURN_WHEN_COMPLETED\",\"msgLevel\":\"ERROR\"}}","DIRECTIVE":"0","STATIC_CONFIG":"false","SESSION_ID":"eaa22ef718d9435b9974b40302dc5463"}, timestamp=1730338612932}]
2024-10-31 09:36:55.840 ERROR 468 --- [ sql.record] p.s.p.f.c.e.r.RocketMQNotifyProducer : 发送消息异常

org.springframework.messaging.MessagingException: connect to 172.16.20.126:10911 failed; nested exception is org.apache.rocketmq.remoting.exception.RemotingConnectException: connect to 172.16.20.126:10911 failed

 

你的期望:

流程设计器配置模型新增触发,模型新增数据,能发起一条流程,通过本地服务入库

如何重现问题:

配置模型触发,场景新增的流程设计器
模型新增数据

回复

共1条回复 我来回复
  • 利江的头像
    利江
    数式Oinone用户
    评论

    mq有问题,namesrv和broker没有配对

    broker.conf的内容配置如下


    brokerClusterName = DefaultCluster
    brokerName = broker-a
    brokerId = 0
    brokerIP1 = 127.0.0.1
    deleteWhen = 04
    fileReservedTime = 48
    brokerRole = ASYNC_MASTER
    flushDiskType = ASYNC_FLUSH
    transactionCheckInterval = 2000
    transactionTimeOut = 2000

    1个月前 0条评论