用代码实现一个java mqtt 群聊完整的项目

好的，下面是实现 Java MQTT 群聊项目的代码示例：

首先，需要引入 Eclipse Paho MQTT 客户端库，可以通过 Maven 进行引入：

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

然后，可以编写一个 `MqttChat` 类作为入口，该类实现了 MQTT 客户端的订阅和发布功能：

import org.eclipse.paho.client.mqttv3.*;

import java.util.Scanner;

public class MqttChat {
    private static final String BROKER_URL = "tcp://localhost:1883";
    private static final String TOPIC_PREFIX = "chat/";

    public static void main(String[] args) throws MqttException {
        // 初始化 MQTT 客户端
        MqttClient client = new MqttClient(BROKER_URL, MqttClient.generateClientId());
        client.connect();

        // 从控制台读取用户名
        Scanner scanner = new Scanner(System.in);
        System.out.print("Enter your username: ");
        String username = scanner.nextLine();
        scanner.close();

        // 订阅聊天室主题
        String topic = TOPIC_PREFIX + "+";
        client.subscribe(topic, (t, message) -> {
            String sender = t.substring(TOPIC_PREFIX.length());
            String text = new String(message.getPayload());
            if (!sender.equals(username)) {
                System.out.println(sender + ": " + text);
            }
        });

        // 发布消息到聊天室主题
        while (true) {
            System.out.print("> ");
            String text = scanner.nextLine();
            if (text.isEmpty()) {
                continue;
            }
            MqttMessage message = new MqttMessage(text.getBytes());
            message.setQos(1);
            client.publish(TOPIC_PREFIX + username, message);
        }
    }
}

运行该程序后，会提示输入用户名，然后等待用户输入消息。当用户输入一条非空消息时，程序就会将该消息发布到以用户名称为后缀的主题上，并将该主题的消息推送给所有订阅了该主题的客户端。如果该主题的发送者不是当前用户，则在控制台上显示该消息。

需要注意的是，该实现只是一个简单的单聊程序，可以通过修改主题名称来实现群聊功能。另外，在实际应用中，需要考虑数据持久化、重连机制等问题。