The heap is constantly increasing

[huifer]

Describe the bug
The heap is constantly increasing

my code

	preHandlerMessage, err := ch.Consume("pre_handler", // queue
		"",    // consumer
		true,  // auto-ack
		false, // exclusive
		false, // no-local
		true,  // no-wait
		nil,   // args
	)


func HandlerDataStorage(messages <-chan amqp.Delivery, ch *amqp.Channel) {

	go func() {

		for d := range messages {
			// todo: storage
			

		}
	}()

	zap.S().Infof(" [*] Waiting for messages. To exit press CTRL+C")
}

[lukebakken]

Hello, thanks for using this library.

Please, help us help you and make it easy for us to reproduce your issue. That means -

• Provide code we can clone and run to see the issue. In your case, this means a simple application to publish messages (or PerfTest) and a consuming application that demonstrates this issue. Please make this code runnable.
• What version of RabbitMQ and Erlang are you using?
• What version of Go?
• How are you collecting that memory information? It is unfamiliar to me.

Thank you.

[huifer]

main code

	CreateRabbitQueue("a")
	ch, err := GRabbitMq.Channel()
	failOnError(err, "Failed to open a channel")

	preHandlerMessage, err := ch.Consume("a", // queue
		"",    // consumer
		true,  // auto-ack
		false, // exclusive
		false, // no-local
		true,  // no-wait
		nil,   // args
	)
go func() {
		for d := range preHandlerMessage {
			zap.S().Infof("%s",string(d.Body))
		}
	}()

push message

for true {
		err = ch.PublishWithContext(context.Background(), "", "a", // routing key
			false, // mandatory
			false, // immediate
			amqp.Publishing{
				ContentType: "text/plain",
				Body:        jsonData,
			})
		failOnError(err, "Failed to publish a message")
		log.Printf(" [x] Sent %s\n", jsonData)
		time.Sleep(1 * time.Second)
	}

• rabbitmq version

version: "3.2"
services:
  rabbitmq:
    image: rabbitmq:3-management-alpine
    container_name: 'rabbitmq'
    ports:
      - 5672:5672
      - 15672:15672
    volumes:
      - ./data/:/var/lib/rabbitmq/
      - ./log/:/var/log/rabbitmq
      - ./plugins:/usr/lib/rabbitmq/plugins
      - ./enabled_plugins:/etc/rabbitmq/enabled_plugins:rw
    environment:
      - RABBITMQ_PLUGINS_DIR=/opt/rabbitmq/plugins:/usr/lib/rabbitmq/plugins
    networks:
      - rabbitmq_go_net

networks:
  rabbitmq_go_net:
    driver: bridge

• Collection method

	_ "net/http/pprof"

• go version

go version go1.22.3 darwin/amd64

[huifer]

[huifer]

[huifer]

On the left is my memory situation after executing for a period of time, and on the back is my memory situation after executing for another period of time

They all send a large number of messages to make this program consume

[huifer]

I will upgrade the version to
github.com/rabbitmq/amqp091-go v1.10.0

Still having issues


[lukebakken]

@huifer please realize that, even with the information you've provided, you're still asking us to put together applications to reproduce this issue.

When I say runnable, I really have to insist that I can clone code and use go run.

Team RabbitMQ is willing to provide free support if you are willing to make it as easy as possible for us.

Think about all of the 100% free software you use, every day, and the amount of time that went into building it. That is why we ask that users do everything they can to make issues as easy as possible to investigate - so we can focus on the actual issue, not putting code together.

https://github.com/rabbitmq/rabbitmq-server/blob/main/COMMUNITY_SUPPORT.md#who-is-eligible-for-community-support

[huifer]

OK I PUSH GIT REPO

[lukebakken]

There's no need to use all-caps. My request is very reasonable. Please provide the link when your code is ready.

[huifer]

@lukebakken https://github.com/huifer/go-rabbit

[lukebakken]

C:\Users\lbakken\development\lukebakken\amqp091-go-268 [main ≡]
> git remote -v
origin  [email protected]:lukebakken/amqp091-go-268.git (fetch)
origin  [email protected]:lukebakken/amqp091-go-268.git (push)
upstream        https://github.com/huifer/go-rabbit.git (fetch)
upstream        https://github.com/huifer/go-rabbit.git (push)

C:\Users\lbakken\development\lukebakken\amqp091-go-268 [main ≡]
> go run .\main.go
# command-line-arguments
.\main.go:10:2: undefined: ConnectToRMQ
.\main.go:11:26: undefined: chann

[huifer]

go build -o .        
./rabbit-example

[huifer]

The TestPushMsg method in mq_test. go is used to simulate sending
I started using IDEA

[lukebakken]

Thank you. I have been so busy working on .NET the past 6 months my golang knowledge has been pushed out of my head.

[huifer]

I am unable to open visualization in this repository using the following command

go tool pprof -http=:9101    http://localhost:19000/debug/pprof/heap