可以发一下你的java代码吗？从截图里看不出来
package com.beidou.utils;
import org.eclipse.paho.client.mqttv3.*;
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;
public class MyMqttClient {
public static final String HOST = "tcp://127.0.0.1:1883";
public static final String TOPIC1 = "111222";
private static final String clientid = "XBG_1";
private MqttClient client;
private MqttConnectOptions options;
private String userName = ""; // 非必须
private String passWord = ""; // 非必须
// 开始连接
public void start() {
try {
// host为主机名，clientid即连接MQTT的客户端ID，一般以唯一标识符表示，MemoryPersistence设置clientid的保存形式，默认为以内存保存
client = new MqttClient(HOST, clientid, new MemoryPersistence());
// MQTT的连接设置
options = new MqttConnectOptions();
// 设置是否清空session,这里如果设置为false表示服务器会保留客户端的连接记录，设置为true表示每次连接到服务器都以新的身份连接
options.setCleanSession(false);
// 设置连接的用户名
options.setUserName(userName);
// 设置连接的密码
options.setPassword(passWord.toCharArray());
// 设置超时时间 单位为秒
options.setConnectionTimeout(10);
// 设置会话心跳时间 单位为秒 服务器会每隔1.5*20秒的时间向客户端发送个消息判断客户端是否在线，但这个方法并没有重连的机制
options.setKeepAliveInterval(20);
// 设置断开后重新连接
options.setAutomaticReconnect(true);
// 设置回调
client.setCallback(new PushCallback());
MqttTopic topic = client.getTopic(TOPIC1);
// setWill方法，如果项目中需要知道客户端是否掉线可以调用该方法。设置最终端口的通知消息 遗嘱
options.setWill(topic, "close".getBytes(), 1, true);
client.connect(options);
// 订阅消息
sub(TOPIC1);
} catch (Exception e) {
e.printStackTrace();
}
}
/**
* 关闭MQTT连接
*/
public void close() throws MqttException {
client.close();
client.disconnect();
}
/**
* 向某个主题发布消息 默认qos：1
*
* @param topic:发布的主题
* @param msg：发布的消息
*/
public void pub(String topic, String msg) throws MqttException {
MqttMessage mqttMessage = new MqttMessage();
//mqttMessage.setQos(2);
mqttMessage.setPayload(msg.getBytes());
MqttTopic mqttTopic = client.getTopic(topic);
MqttDeliveryToken token = mqttTopic.publish(mqttMessage);
token.waitForCompletion();
}
/**
* 向某个主题发布消息
*
* @param topic: 发布的主题
* @param msg: 发布的消息
* @param qos: 消息质量 Qos：0、1、2
*/
public void pub(String topic, String msg, int qos) throws MqttException {
MqttMessage mqttMessage = new MqttMessage();
mqttMessage.setQos(qos);
mqttMessage.setPayload(msg.getBytes());
MqttTopic mqttTopic = client.getTopic(topic);
MqttDeliveryToken token = mqttTopic.publish(mqttMessage);
token.waitForCompletion();
}
/**
* 订阅某一个主题 ，此方法默认的的Qos等级为：1
*
* @param topic 主题
*/
public void sub(String topic) throws MqttException {
client.subscribe(topic);
}
/**
* 订阅某一个主题，可携带Qos
*
* @param topic 所要订阅的主题
* @param qos 消息质量：0、1、2
*/
public void sub(String topic, int qos) throws MqttException {
client.subscribe(topic, qos);
}
/**
* main函数自己测试用
*/
public static void main(String[] args) throws MqttException {
MyMqttClient mqttConnect = new MyMqttClient();
mqttConnect.start();
}
}
先使用其它mqtt客户端工具连接这个MQTT broker，看看能不能获得数据。例如mosquitto或者MQTTX
以mosquitto的命令行为例子
mosquitto_sub -h 127.0.0.1 -t 111222
这里的host和topic需要和你的实际情况对应
从你的截图来看，你的mosquitto启动为local only模式，这意味着只有你这台电脑本身可以连接这个MQTT broker (127.0.0.1)。
Starting in local only mode.
修改mosquitto.conf并加入以下行然后重启mosquitto
listener 1883
测试前在另一台电脑连接这个MQTT broker看看能不能连接
我可以ping通网关和服务器的ip（127.0.0.1），但是服务器就是接收不到网关发出的定位数据，我用测试的软件也收不到，这是为什么？如果用mqtt.bconimg.com这个地址就是可以正常接收的。
127.0.0.1是一个特殊的IP地址，被称为"本地回环地址"或"环回地址"。它是一个保留的IPv4地址，用于在网络中引用本地计算机或本地主机。当计算机尝试通过网络协议与自身进行通信时，可以使用127.0.0.1作为目标IP地址。
换句话说，这个IP只有这个电脑本机可以访问。
请使用局域网IP比如192.168.1.2之类的，具体的IP可以看看你的网络属性。为了确保你的MQTT broker在其它设备上也可以访问，首先你可以用另一台电脑或者手机来连接这个MQTT看看能不能连通
我搜了一下，确实是ip搞错了，现在可以接收到数据了，谢谢！
