var manager2 = new ClusterTransportManager(result_config)
manager2.start
var producer = new MessageProducer(manager2)
producer.start
var message=new MyMessageListener(batchsize,producer,result_topic,redis)
var consumerConfig: ConsumerConfig = new ConsumerConfig
var manager = new ClusterTransportManager(config)
messageConsumer = new MessageConsumer(consumerConfig, manager, null)
println("start consumer .....")
messageConsumer.start
while (true) {
messageConsumer.pull(topic, message)
}
------- Выше моя основная функция.
Это то, что я написал на языке scala, назвав java-интерфейс mq (как для производства, так и для потребления), постоянно исключая процентное потребление из MQ pull и возвращая результат в другую тему через while (true) {pull (topic, MyMessageListener)} , Я контролировал память стека, и память увеличилась.
Как показано здесь, я использую инструменты для мониторинга памяти в течение трех дней. ，, но я не использовал класс и метод StructField. Очень озадачен ~~ И никакой конкретной причины утечки памяти не найдено.
Blockquote