在Java中，您可以使用 Eclipse Paho MQTT 客户端库来连接到 MQTT 服务器。以下是一个简单的示例代码，展示如何使用 Eclipse Paho MQTT 客户端库来连接到 MQTT 服务器：

import org.eclipse.paho.client.mqttv3.MqttClient;import org.eclipse.paho.client.mqttv3.MqttConnectOptions;public class MQTTClient {public static void main(String[] args) {String broker = "tcp://broker.hivemq.com:1883";String clientId = "JavaClient";try {MqttClient client = new MqttClient(broker, clientId);MqttConnectOptions connOpts = new MqttConnectOptions();connOpts.setCleanSession(true);client.connect(connOpts);System.out.println("Connected to MQTT broker: " + broker);// Do something with the MQTT clientclient.disconnect();System.out.println("Disconnected from MQTT broker");} catch (Exception e) {e.printStackTrace();}}}

在这个示例中，我们创建了一个 MqttClient 对象，并指定了要连接到的 MQTT 服务器的地址和客户端ID。然后，我们创建了一个 MqttConnectOptions 对象，设置了 cleanSession 选项，并调用 connect() 方法来连接到 MQTT 服务器。最后，我们做一些操作，然后调用 disconnect() 方法来断开与 MQTT 服务器的连接。

您可以根据需要修改以上代码，以满足您的具体需求。请注意，您需要在项目中添加 Eclipse Paho MQTT 客户端库的依赖，以便能够使用该库。