search

apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.28k stars 409 forks source link

producer.SendAsync panic: runtime error: invalid memory address or nil pointer dereference #1102

Closed 474903784 closed 9 months ago

474903784 commented 9 months ago

panic: runtime error: invalid memory address or nil pointer dereference [signal SIGSEGV: segmentation violation code=0x1 addr=0x0 pc=0x1b8491e]

goroutine 4896 [running]: github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).ProcessSendResponse(0x2658e60?, {0xc001d5dee0?, 0xffffffffffffffff?}, 0x0, 0xc000680470?, {0xc001f540b8?, 0x1?, 0x1?}) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:730 +0x3e github.com/apache/rocketmq-client-go/v2/producer.(defaultProducer).sendAsync.func1(0xc0025c9b60?, {0x26389c0, 0xc000680470}) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/producer/producer.go:411 +0x128 github.com/apache/rocketmq-client-go/v2/internal.(rmqClient).InvokeAsync.func1(0x1e34160?) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/client.go:591 +0x2b github.com/apache/rocketmq-client-go/v2/internal/remote.(ResponseFuture).executeInvokeCallback.func1() /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/remote/future.go:50 +0x2a sync.(Once).doSlow(0xc002c58720?, 0x0?) /usr/local/go/src/sync/once.go:74 +0xc2 sync.(Once).Do(...) /usr/local/go/src/sync/once.go:65 github.com/apache/rocketmq-client-go/v2/internal/remote.(ResponseFuture).executeInvokeCallback(0xc0029e7040?) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/remote/future.go:48 +0x45 github.com/apache/rocketmq-client-go/v2/internal/remote.(remotingClient).receiveAsync(0x1f49ca0?, 0x0?) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/remote/remote_client.go:139 +0x34 github.com/apache/rocketmq-client-go/v2/internal/remote.(remotingClient).InvokeAsync.func1() /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/remote/remote_client.go:129 +0x2f github.com/apache/rocketmq-client-go/v2/primitive.WithRecover(0xc000228360?) /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/primitive/base.go:100 +0x3e created by github.com/apache/rocketmq-client-go/v2/internal/remote.(remotingClient).InvokeAsync /go/pkg/mod/github.com/apache/rocketmq-client-go/v2@v2.1.2-0.20230803074138-7eedaf948c60/internal/remote/remote_client.go:128 +0x20c

474903784 commented 9 months ago

image err：request timeout

cococolanosugar commented 9 months ago

Maybe you need to pass a clean ctx for AsyncPublish function.

474903784 commented 9 months ago

miss return when err != nil，so occur panic: runtime error: invalid memory address or nil pointer dereference