openbilibili/app/interface/main/app-wall/service/unicom/databus.go

package unicom

import (
	"context"
	"strconv"

	"go-common/app/interface/main/app-wall/model/unicom"
	log "go-common/library/log"
)

func (s *Service) addUserBindState(u *unicom.UserBindInfo) {
	select {
	case s.userBindCh <- u:
	default:
		log.Warn("add user bind state buffer is full")
	}
}

func (s *Service) userbindConsumer() {
	defer s.waiter.Done()
	for {
		i, ok := <-s.userBindCh
		if !ok {
			return
		}
		var (
			err error
		)
		switch v := i.(type) {
		case *unicom.UserBindInfo:
			if err = s.userbindPub.Send(context.TODO(), strconv.FormatInt(v.MID, 10), v); err != nil {
				log.Error("s.userbindSub.Send error(%v)", err)
				continue
			}
			log.Info("s.userbindSub.Send(%+v) success", v)
		}
	}
}