liulei/jx-callback
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

- change OrderMsgHandlerRoutinue to orderMsgHandlerRoutine

Browse Source
This commit is contained in:
gazebo
2018-06-19 23:19:33 +08:00
parent 2818b06512
commit e8f6264b37
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
business/jd/controller/order.go
View File

@@ -27,7 +27,7 @@ func InitOrder() {
errChecker = new(corm.MysqlErrorChecker) errChecker = new(corm.MysqlErrorChecker)
orderMsgChan = make(chan jdapi.JDOrderMsg, 128) orderMsgChan = make(chan jdapi.JDOrderMsg, 128)
go orderMsgHandlerRoutinue() go orderMsgHandlerRoutine()
// todo 这样操作在有多个进程时，会有问题 // todo 这样操作在有多个进程时，会有问题
// 另外当前这个模式可能会出现同一个定单的消息，虽然远程推送过来顺序是对的，但经过处理后推送到freshfood时乱序（因为每个消息的处理时间是不确定的） // 另外当前这个模式可能会出现同一个定单的消息，虽然远程推送过来顺序是对的，但经过处理后推送到freshfood时乱序（因为每个消息的处理时间是不确定的）
@@ -57,7 +57,7 @@ func handlePendingOrderMsg() {
func orderMsgHandlerRoutinue() { func orderMsgHandlerRoutinue() {
for { for {
msg := <-orderMsgChan msg := <-orderMsgChan
globals.SugarLogger.Debugf("OrderMsgHandlerRoutinue:%v", msg) globals.SugarLogger.Debugf("orderMsgHandlerRoutine:%v", msg)
go handleOrderMsg(&msg) go handleOrderMsg(&msg)
} }
} }