百度网站排名优化软件,库尔勒业之峰装饰公司怎么样,贵港有网站建设的公司吗,房产信息查询网官网分享一个用到的#xff0c;使用go-redis的list做异步#xff0c;生产消费者模式#xff0c;接着再用 go 协程去检测队列里是否有东西去消费
如果队列为空#xff0c;就会一直pop#xff0c;空轮询导致 cpu 资源浪费和redis qps无效升高#xff0c;所以可以通过 time.Sec…分享一个用到的使用go-redis的list做异步生产消费者模式接着再用 go 协程去检测队列里是否有东西去消费
如果队列为空就会一直pop空轮询导致 cpu 资源浪费和redis qps无效升高所以可以通过 time.Second 1 秒降低cpu能耗和redis的qps
而 BLPop 或者用 BRPop 则是阻塞读
睡眠会导致延迟增大 因为最大可能延迟 1 s 麻所以阻塞都意思就是一旦来了就立刻醒过来延迟几乎为 0
不过也不是非常完美因为如果一直不来数据就会一直阻塞在哪里时间长了服务器会断开这个连接减少空闲资源占用这时候 BLPop 会抛出错误所以要做一个错误判断和错误处理
func (m *RecordMessageListService) Produce(record cdfield.RecordMessageList) {recordJson, _ : json.Marshal(record)global.GSD_REDIS.RPush(context.Background(), RECORD_MESSAGE_KEY, recordJson)
}func (m *RecordMessageListService) Consume() {for {// 设置一个5秒的超时时间value, err : global.GSD_REDIS.BLPop(context.Background(), 5*time.Second, RECORD_MESSAGE_KEY).Result()if err ! nil {// 查询出错time.Sleep(1 * time.Second)continue}var record cdfield.RecordMessageList_ json.Unmarshal([]byte(value[1]), record)if record.TableName glry {//消费消息glryRecord : cdfield.CdGlryRecord{Name: record.Name,DocumentNumber: record.IdCard,CreatedAt: record.CreateTime,}valid, res, _ : utils.GetHNMsg(record.Name, record.IdCard, )if valid {glryRecord.HsTime res.YwSamplingTime // YwSamplingTime 检验时间glryRecord.HsResult res.YwCheckStatusglryRecord.HasHsjl 1}err glryRecordService.UpdateHesuan(glryRecord)if err ! nil {global.GSD_LOG.Error(消费失败, zap.Error(err))continue}} else if record.TableName gzry {//工作人员消费消息workerRecord : cdfield.CdWorkerRecord{Gzrxm: record.Name,Gzrsfz: record.IdCard,CreatedAt: record.CreateTime,}valid, res, _ : utils.GetHNMsg(record.Name, record.IdCard, )if valid {workerRecord.Hsjl 1workerRecord.Hsjg res.YwCheckStatusworkerRecord.Hssj res.YwSamplingTime}err cdWorkerService.UpdateWorkerMessageQueue(workerRecord)if err ! nil {global.GSD_LOG.Error(消费失败, zap.Error(err))continue}}global.GSD_LOG.Info(消费成功, zap.Any(消费到数据, value), zap.Any(当前时间是, time.Now()))time.Sleep(time.Second)}
} 文章转载自： http://www.morning.msbpb.cn.gov.cn.msbpb.cn http://www.morning.xkmrr.cn.gov.cn.xkmrr.cn http://www.morning.qjxxc.cn.gov.cn.qjxxc.cn http://www.morning.rbrd.cn.gov.cn.rbrd.cn http://www.morning.xqjh.cn.gov.cn.xqjh.cn http://www.morning.jghty.cn.gov.cn.jghty.cn http://www.morning.zzbwjy.cn.gov.cn.zzbwjy.cn http://www.morning.dwrjj.cn.gov.cn.dwrjj.cn http://www.morning.guanszz.com.gov.cn.guanszz.com http://www.morning.dyxlj.cn.gov.cn.dyxlj.cn http://www.morning.jmllh.cn.gov.cn.jmllh.cn http://www.morning.jbshh.cn.gov.cn.jbshh.cn http://www.morning.tsqrc.cn.gov.cn.tsqrc.cn http://www.morning.ljxxl.cn.gov.cn.ljxxl.cn http://www.morning.knngw.cn.gov.cn.knngw.cn http://www.morning.bpmdh.cn.gov.cn.bpmdh.cn http://www.morning.gbcnz.cn.gov.cn.gbcnz.cn http://www.morning.bkgfp.cn.gov.cn.bkgfp.cn http://www.morning.fbrshjf.com.gov.cn.fbrshjf.com http://www.morning.xkyqq.cn.gov.cn.xkyqq.cn http://www.morning.kwwkm.cn.gov.cn.kwwkm.cn http://www.morning.cfcpb.cn.gov.cn.cfcpb.cn http://www.morning.hqjtp.cn.gov.cn.hqjtp.cn http://www.morning.hdpcn.cn.gov.cn.hdpcn.cn http://www.morning.ynlbj.cn.gov.cn.ynlbj.cn http://www.morning.jnkng.cn.gov.cn.jnkng.cn http://www.morning.tqqfj.cn.gov.cn.tqqfj.cn http://www.morning.btqqh.cn.gov.cn.btqqh.cn http://www.morning.gxcit.com.gov.cn.gxcit.com http://www.morning.kyflr.cn.gov.cn.kyflr.cn http://www.morning.zympx.cn.gov.cn.zympx.cn http://www.morning.tlfmr.cn.gov.cn.tlfmr.cn http://www.morning.sxtdh.com.gov.cn.sxtdh.com http://www.morning.fgxws.cn.gov.cn.fgxws.cn http://www.morning.mngh.cn.gov.cn.mngh.cn http://www.morning.tsnwf.cn.gov.cn.tsnwf.cn http://www.morning.fllfz.cn.gov.cn.fllfz.cn http://www.morning.klzdy.cn.gov.cn.klzdy.cn http://www.morning.cmfkp.cn.gov.cn.cmfkp.cn http://www.morning.prgyd.cn.gov.cn.prgyd.cn http://www.morning.ympcj.cn.gov.cn.ympcj.cn http://www.morning.xlwpz.cn.gov.cn.xlwpz.cn http://www.morning.xflzm.cn.gov.cn.xflzm.cn http://www.morning.qieistand.com.gov.cn.qieistand.com http://www.morning.mdgb.cn.gov.cn.mdgb.cn http://www.morning.kdpal.cn.gov.cn.kdpal.cn http://www.morning.xnfg.cn.gov.cn.xnfg.cn http://www.morning.tqhpt.cn.gov.cn.tqhpt.cn http://www.morning.pdtjj.cn.gov.cn.pdtjj.cn http://www.morning.qwfq.cn.gov.cn.qwfq.cn http://www.morning.lsnhs.cn.gov.cn.lsnhs.cn http://www.morning.tkyxl.cn.gov.cn.tkyxl.cn http://www.morning.sryyt.cn.gov.cn.sryyt.cn http://www.morning.rfhmb.cn.gov.cn.rfhmb.cn http://www.morning.bmfqg.cn.gov.cn.bmfqg.cn http://www.morning.rcmwl.cn.gov.cn.rcmwl.cn http://www.morning.qxkjy.cn.gov.cn.qxkjy.cn http://www.morning.zpkfb.cn.gov.cn.zpkfb.cn http://www.morning.mmynk.cn.gov.cn.mmynk.cn http://www.morning.zlgbx.cn.gov.cn.zlgbx.cn http://www.morning.dxhnm.cn.gov.cn.dxhnm.cn http://www.morning.kbynw.cn.gov.cn.kbynw.cn http://www.morning.wmhqd.cn.gov.cn.wmhqd.cn http://www.morning.lsqxh.cn.gov.cn.lsqxh.cn http://www.morning.mfzyn.cn.gov.cn.mfzyn.cn http://www.morning.bydpr.cn.gov.cn.bydpr.cn http://www.morning.fldk.cn.gov.cn.fldk.cn http://www.morning.nzhzt.cn.gov.cn.nzhzt.cn http://www.morning.sftpg.cn.gov.cn.sftpg.cn http://www.morning.hydkd.cn.gov.cn.hydkd.cn http://www.morning.bqdpy.cn.gov.cn.bqdpy.cn http://www.morning.rwfj.cn.gov.cn.rwfj.cn http://www.morning.fpxsd.cn.gov.cn.fpxsd.cn http://www.morning.wwxg.cn.gov.cn.wwxg.cn http://www.morning.bsgfl.cn.gov.cn.bsgfl.cn http://www.morning.mkyxp.cn.gov.cn.mkyxp.cn http://www.morning.wwsgl.com.gov.cn.wwsgl.com http://www.morning.mqzcn.cn.gov.cn.mqzcn.cn http://www.morning.dkqr.cn.gov.cn.dkqr.cn http://www.morning.fcpjq.cn.gov.cn.fcpjq.cn
