chengyb 5年前

//获取OAuth授权结果
               QueryAuthResult queryAuthResult;
               try
               {
                   queryAuthResult = ComponentContainer.GetQueryAuthResult(component_AppId, auth_code);
               }
               catch (Exception ex)
               {
                   throw new Exception("QueryAuthResult：" + ex.Message);
               }
               #endregion

这个也是有问题的，直接用api来就没事

qq29366365 5年前

使用的代码是完全copy来自 demo-微信小程序，引用的其他类库版本号
Senparc.CO2NET.APM.dll----------------------------------------------------------0.6.102.0
Senparc.CO2NET.Cache.Memcached.dll----------------------------------------------3.4.102.1
Senparc.CO2NET.Cache.Redis.dll--------------------------------------------------3.6.102.0
Senparc.CO2NET.Cache.Redis.RedLock.dll------------------------------------------2.2.4.0
Senparc.CO2NET.dll--------------------------------------------------------------1.0.102.0
Senparc.NeuChar.App.dll---------------------------------------------------------0.6.102.0
Senparc.NeuChar.dll-------------------------------------------------------------1.0.102.0
Senparc.WebSocket.dll-----------------------------------------------------------0.9.0.15187
Senparc.Weixin.Cache.Memcached.dll----------------------------------------------2.5.0.34741
Senparc.Weixin.Cache.Redis.dll--------------------------------------------------2.7.102.0
Senparc.Weixin.Cache.Redis.RedLock.dll------------------------------------------1.0.1.0
Senparc.Weixin.dll--------------------------------------------------------------6.6.102.0
Senparc.Weixin.MP.dll-----------------------------------------------------------16.9.102.0
Senparc.Weixin.MP.MvcExtension.dll----------------------------------------------7.4.0.34742
Senparc.Weixin.Open.dll---------------------------------------------------------4.7.0.34741
Senparc.Weixin.TenPay.dll-------------------------------------------------------1.5.0.34741
Senparc.Weixin.Work.dll---------------------------------------------------------3.7.0.34741
Senparc.Weixin.WxOpen.dll-------------------------------------------------------3.7.102.0

Senparc 5年前 编辑于 2019年10月26日 16:02

是否能把你能重现问题的最小化的代码发一个过来（可以跑起来的项目），我可以实景测试一下：zsu@senparc.com

chengyb 5年前

//消息去重
           if (MessageContextGlobalConfig.UseMessageContext)
           {
               var omit = OmitRepeatedMessageFunc == null || OmitRepeatedMessageFunc(RequestMessage);

               //使用分布式锁，已支持分布式上下文缓存
               var lockKey = this.GetInsertMessageKey();
               var cache = CacheStrategyFactory.GetObjectCacheStrategyInstance();
               using (cache.BeginCacheLock(MessageContextGlobalConfig.MESSAGE_INSERT_LOCK_NAME, lockKey))
               {
                   #region 消息去重

                   var messageContext = GetCurrentMessageContext().ConfigureAwait(false).GetAwaiter().GetResult();
                   if (omit &&
                       OmitRepeatedMessage &&
                       messageContext.RequestMessages.Count > 0
                        //&& !(RequestMessage is RequestMessageEvent_Merchant_Order)批量订单的MsgId可能会相同
                        )
                   {
                       //lastMessage必定有值（除非极端小的过期时间条件下，几乎不可能发生）
                       var lastMessage = messageContext.RequestMessages.Last();

                       if (
                           //使用MsgId去重
                           (lastMessage.MsgId != 0 && lastMessage.MsgId == RequestMessage.MsgId) ||
                           //使用CreateTime去重（OpenId对象已经是同一个）
                           (lastMessage.MsgId == RequestMessage.MsgId &&
                                lastMessage.CreateTime == RequestMessage.CreateTime &&
                                lastMessage.MsgType == RequestMessage.MsgType)
                           )
                       {
                           MarkRepeatedMessage();//标记为已重复
                       }

                       //判断特殊事件
                       if (!MessageIsRepeated && SpecialDeduplicationAction != null && SpecialDeduplicationAction(RequestMessage, this))
                       {
                           MarkRepeatedMessage();//标记为已重复
                       }
                   }

                   #endregion

                   //在消息没有被去重的情况下记录上下文
                   if (!MessageIsRepeated && RequestMessage.MsgType != RequestMsgType.Unknown)
                   {
                       //这里不能用队列，因为需要确保解锁之前缓存已经录入信息
                       GlobalMessageContext.InsertMessage(RequestMessage);
                   }
               }
           }

chengyb 5年前

确实有这样的问题

应是缓存那里有问题，还没仔细查

MessageContextGlobalConfig.UseMessageContext = false 可以跳过，但回复消息处还是有问题

qq29366365 5年前

.net 4.5更新到最新版的也有这样的问题 没有任何异常信息

Senparc 5年前

这是算线程卡死了吗？

有没有能够重现问题的最简化的代码可以发到 zsu@senparc.com 帮您看一下。