huanghaosheng/VLoop
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: 注释从英文改为中文

Browse Source
This commit is contained in:
Leon
2025-12-30 01:26:24 +08:00
parent 631cb2203f
commit 116724a845
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
backend/internal/worker/socialworker.go
View File

@@ -59,7 +59,7 @@ func (w *SocialWorker) Run(ctx context.Context) error {
func (w *SocialWorker) handleDelivery(ctx context.Context, d amqp.Delivery) { func (w *SocialWorker) handleDelivery(ctx context.Context, d amqp.Delivery) {
if err := w.process(ctx, d.Body); err != nil { if err := w.process(ctx, d.Body); err != nil {
log.Printf("social worker: failed to process message: %v", err) log.Printf("social worker: failed to process message: %v", err)
// Retry on DB/transient errors. // 重新入队，稍后重试
_ = d.Nack(false, true) _ = d.Nack(false, true)
return return
} }
@@ -69,7 +69,7 @@ func (w *SocialWorker) handleDelivery(ctx context.Context, d amqp.Delivery) {
func (w *SocialWorker) process(ctx context.Context, body []byte) error { func (w *SocialWorker) process(ctx context.Context, body []byte) error {
var evt rabbitmq.SocialEvent var evt rabbitmq.SocialEvent
if err := json.Unmarshal(body, &evt); err != nil { if err := json.Unmarshal(body, &evt); err != nil {
// Poison message: drop it to avoid infinite retry loop. // 解析事件失败，直接丢弃
return nil return nil
} }
if evt.FollowerID == 0 || evt.VloggerID == 0 { if evt.FollowerID == 0 || evt.VloggerID == 0 {