unity mqtt服务器代码

以下是使用 Unity 和 MQTT 实现基本发布和订阅功能的示例代码：

using System.Collections;
using System.Collections.Generic;
using UnityEngine;
using uPLibrary.Networking.M2Mqtt;
using uPLibrary.Networking.M2Mqtt.Messages;
using System;

public class MqttController : MonoBehaviour
{
    private MqttClient client;
    public string brokerIpAddress = "broker.hivemq.com"; // MQTT broker 的 IP 地址
    public int brokerPort = 1883; // MQTT broker 的端口号
    public string clientId = "UnityClient"; // MQTT 客户端 ID
    public string topic = "testTopic"; // MQTT 主题

    void Start()
    {
        // 通过 IP 地址和端口号创建 MqttClient 实例
        client = new MqttClient(brokerIpAddress, brokerPort, false, null);
        client.MqttMsgPublishReceived += Client_MqttMsgPublishReceived;

        // 生成随机的客户端 ID，并连接到 MQTT broker
        clientId = Guid.NewGuid().ToString();
        client.Connect(clientId);

        // 订阅主题
        client.Subscribe(new string[] { topic }, new byte[] { MqttMsgBase.QOS_LEVEL_AT_MOST_ONCE });
    }

    void Update()
    {
        // 每秒发布一条消息
        client.Publish(topic, System.Text.Encoding.UTF8.GetBytes("Hello, World!"));
    }

    void Client_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
    {
        // 处理接收到的消息
        string message = System.Text.Encoding.UTF8.GetString(e.Message);
        Debug.Log("Received message: " + message);
    }

    void OnDestroy()
    {
        // 断开连接
        client.Disconnect();
    }
}

这是一个简单的 MQTT 客户端，它连接到指定的 MQTT broker，订阅指定的主题，并每秒发布一条消息。在 `Client_MqttMsgPublishReceived` 中处理接收到的消息，可以根据需要进行修改。需要注意的是，这里使用了 `uPLibrary.Networking.M2Mqtt` 库，需要在 Unity 项目中导入该库的 DLL 文件。