您的问题是使用者正在运行，然后立即关闭。
尝试将其添加到您的使用者中：
consumer.setMessageListener(listner); try { System.in.read(); } catch (IOException e) { e.printStackTrace(); } connection.close();这将一直等到您按下某个键后才停止。
要考虑的其他事项：
- 使用finally块结束
- Java命名约定鼓励将大写字母用于类的首字母
