生产者
public class Procuder {
public static void main(String[] args) throws IOException, TimeoutException {
ConnectionFactory connectionFactory= new ConnectionFactory();
connectionFactory.setHost("10.10.10.10&#
生产者
public class Procuder {
public static void main(String[] args) throws IOException, TimeoutException {
ConnectionFactory connectionFactory= new ConnectionFactory();
connectionFactory.setHost("10.10.10.10&#