您好，如题
@Configuration
public class RabbitMQConfig {
@Bean
public ConnectionFactory getFactory(){
ConnectionFactory factory=new ConnectionFactory();
factory.setHost(“192.168.2.111”);
factory.setPort(5672);
return factory;
}
}

public void send(String topic, MessageEntity entity){
    String id=messageService.insertMessage(entity);
    try(Connection connection=factory.newConnection();
        Channel channel=connection.createChannel();
        ){
        channel.queueDeclare(topic,true,false,false,null);
        HashMap map=new HashMap();
        map.put("messageId",id);
        AMQP.BasicProperties properties=new AMQP.BasicProperties().builder().headers(map).build();
        channel.basicPublish("",topic,properties,entity.getMsg().getBytes(StandardCharsets.UTF_8));
        log.debug("消息发送成功");
    }catch (Exception e){
        log.error("执行异常",e);
        throw new EmosException("向MQ发送消息失败");

    }
}