1.使用的包直接导的metaq软件中的lib里面的所有 2.主要写的生产者和消费者 3.另外特别注意需要注册 topic 在metaq/conf下面的server.ini 上代码：生产者 package examples; /* 生产者 本次用的控制台输入方式。 */ import java.io.BufferedReader; import java.io.InputStreamReader; import