c# m2mqtt 无法从服务器读取数据

Question

服务器用的apache apollo
publish：
        static void Main(string[] args)
        {
            MqttClient c = new MqttClient("localhost");            string clientId = Guid.NewGuid().ToString();
            c.Connect(clientId, "admin", "password");
            //byte[] body = System.Text.Encoding.Default.GetBytes("/topic/testsss");
            c.Publish("/topic/test", System.Text.Encoding.Default.GetBytes("让我调试出来吧！！"), MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE, false);
            Console.WriteLine(c.IsConnected);
            Console.ReadKey();
        }subscribe:
        private static string _x;
        static void Main(string[] args)
        {
            MqttClient c = new MqttClient("localhost");
            c.MqttMsgPublishReceived += mqttClient_MqttMsgPublishReceived;
            string clientId = Guid.NewGuid().ToString();
            c.Connect(clientId, "admin", "password");
            c.Subscribe(new string[] { "/topic/test" }, new byte[] { uPLibrary.Networking.M2Mqtt.Messages.MqttMsgBase.QOS_LEVEL_EXACTLY_ONCE });            Console.WriteLine(_x);
            Console.ReadKey();        }        static void mqttClient_MqttMsgPublishReceived(object sender, MqttMsgPublishEventArgs e)
        {
            //处理接收到的消息  
            string msg = System.Text.Encoding.Default.GetString(e.Message);
            _x = msg;
        }

Answer 1

需要加端口， 默认端口1883var client = new MqttClient(brokerHostName, brokerPort, false, null, null, MqttSslProtocols.None);

Answer 2

apollo的tcp连接使用端口61613,
var client= new MqttClient(Broker域名或者IP, 61613, false, null, null, MqttSslProtocols.None);