Producer cannot shutdown completely

[a-tony]

org.apache.rocketmq rocketmq-client 4.9.2

这个办法根本使用producer.shutdown();根本无法关闭

[lizhiboo]

org.apache.rocketmq rocketmq-client 4.9.2
这个办法根本使用producer.shutdown();根本无法关闭

Can u describe the concrete class and the correct error message?

[a-tony]

public class SyncProducer { public static void main(String[] args) throws Throwable { //1、创建消息生产者producer，并指定生产者的组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); //2、指定nameserver地址，可以用分号隔开10.0.0.99:9876;10.0.0.68:9876 producer.setNamesrvAddr("10.0.0.99:9876"); //3、启动producer producer.start(); //4、创建消息对象，指定主题Topic，Tag和消息体 for (int i = 0; i < 1; i++) { /** * 参数一：消息的Topic名称，自定义 * 参数二：消息的Tag名称，自定义 * 参数三：消息的内容 * */ Message msg = new Message("base", "tag1", ("Hello RocketMQ" + i).getBytes(StandardCharsets.UTF_8)); //5、发送消息 SendResult result = producer.send(msg); SendStatus status = result.getSendStatus();//发送状态 String msgId = result.getMsgId();//消息id int queueId = result.getMessageQueue().getQueueId();//队列id System.out.println("发送结果&gt;" + result); TimeUnit.SECONDS.sleep(1);//休眠1秒 } //6、关闭生产者producer producer.shutdown(); System.out.println("ffffff"); } } 当执行到//6、关闭生产者producer producer.shutdown();程序main无法正常退出，线程还在挂起<dependency&gt; <groupId&gt;org.apache.rocketmq</groupId&gt; <artifactId&gt;rocketmq-client</artifactId&gt; <version&gt;4.9.2</version&gt; </dependency&gt; 4.9.2有这样的问题，4.4.0没有这样的问题，其他的版本我没测试

[RongtongJin]

public class SyncProducer { public static void main(String[] args) throws Throwable { //1、创建消息生产者producer，并指定生产者的组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); //2、指定nameserver地址，可以用分号隔开10.0.0.99:9876;10.0.0.68:9876 producer.setNamesrvAddr("10.0.0.99:9876"); //3、启动producer producer.start(); //4、创建消息对象，指定主题Topic，Tag和消息体 for (int i = 0; i < 1; i++) { /** * 参数一：消息的Topic名称，自定义 * 参数二：消息的Tag名称，自定义 * 参数三：消息的内容 * */ Message msg = new Message("base", "tag1", ("Hello RocketMQ" + i).getBytes(StandardCharsets.UTF_8)); //5、发送消息 SendResult result = producer.send(msg); SendStatus status = result.getSendStatus();//发送状态 String msgId = result.getMsgId();//消息id int queueId = result.getMessageQueue().getQueueId();//队列id System.out.println("发送结果>" + result); TimeUnit.SECONDS.sleep(1);//休眠1秒 } //6、关闭生产者producer producer.shutdown(); System.out.println("ffffff"); } } 当执行到//6、关闭生产者producer producer.shutdown();程序main无法正常退出，线程还在挂起<dependency> <groupId>org.apache.rocketmq</groupId> <artifactId>rocketmq-client</artifactId> <version>4.9.2</version> </dependency> 4.9.2有这样的问题，4.4.0没有这样的问题，其他的版本我没测试

Good catch！We will fix it ASAP.

[Git-Yang]

public class SyncProducer { public static void main(String[] args) throws Throwable { //1、创建消息生产者producer，并指定生产者的组名 DefaultMQProducer producer = new DefaultMQProducer("group1"); //2、指定nameserver地址，可以用分号隔开10.0.0.99:9876;10.0.0.68:9876 producer.setNamesrvAddr("10.0.0.99:9876"); //3、启动producer producer.start(); //4、创建消息对象，指定主题Topic，Tag和消息体 for (int i = 0; i < 1; i++) { /** * 参数一：消息的Topic名称，自定义 * 参数二：消息的Tag名称，自定义 * 参数三：消息的内容 * */ Message msg = new Message("base", "tag1", ("Hello RocketMQ" + i).getBytes(StandardCharsets.UTF_8)); //5、发送消息 SendResult result = producer.send(msg); SendStatus status = result.getSendStatus();//发送状态 String msgId = result.getMsgId();//消息id int queueId = result.getMessageQueue().getQueueId();//队列id System.out.println("发送结果>" + result); TimeUnit.SECONDS.sleep(1);//休眠1秒 } //6、关闭生产者producer producer.shutdown(); System.out.println("ffffff"); } } 当执行到//6、关闭生产者producer producer.shutdown();程序main无法正常退出，线程还在挂起 org.apache.rocketmq rocketmq-client 4.9.2 4.9.2有这样的问题，4.4.0没有这样的问题，其他的版本我没测试

Good catch！We will fix it ASAP.

I just identified this problem. The reason why the thread cannot exit is that the internally built ScheduledExecutorService thread pool cannot exit.

[panzhi33]

My problem, i will fix it

[a-tony]

Thanks&nbsp;all