以下是使用Eclipse Paho客户端库的Java代码示例，用于连接到MQTT代理并发布和订阅消息。

首先，需要添加Maven依赖项到项目中：

<dependency>  <groupId>org.eclipse.paho</groupId>  <artifactId>org.eclipse.paho.client.mqttv3</artifactId>  <version>1.2.5</version>  
</dependency>

然后，可以编写Java代码来连接到MQTT代理并发布和订阅消息：

import org.eclipse.paho.client.mqttv3.*;  
import org.eclipse.paho.client.mqttv3.persist.MemoryPersistence;  public class MqttExample {  public static void main(String[] args) {  try {  // 创建MQTT客户端实例，使用内存存储持久化客户端配置  MqttClient client = new MqttClient("tcp://broker.hivemq.com:1883", MqttClient.generateClientId(), new MemoryPersistence());  // 创建MQTT连接参数，包括用户名和密码（如果需要）  MqttConnectOptions options = new MqttConnectOptions();