我们使用java实现生产者和消费者（MQTT使用wmqtt.jar），服务器采用mosquitto。