MqttClient 객체의 동기화 및 비동기 인터페이스가 작동하지 않습니다.

Question

MqttClient 유형의 client을 만들었으며 아래 코드와 같이 클라이언트를 만들고 Asynchronous callback입니다. 문제는,

1 - 내가 실행할 때, System.out.println("Client is Connected");가 나타납니다. 그러나 응답이 없습니다또는 onFailure에서 왜 응답합니까? 나는 코드에서 잘못하고있다.

2-i는 static IMqttAsyncClient asynchClientCB = new IMqttAsyncClient() 인터페이스를 구현했지만, MqttClient 유형의 클라이언트를 가지고 있기 때문에이 IMqttAsyncClient 인터페이스를 사용할 수 없습니다. 나는 mqttAsynchClien을 사용하려고 시도했지만, java를위한 프로그램이 아니기 때문에 Android을 사용할 수 없습니다. IMqttAsyncClient 인터페이스를 사용하는 방법.? 아래의 코드 "Updated_code_1"에서 Update_1

, 내가 코드를 약간 수정,하지만 난 onSuccess 동기 콜백 메시지를 인쇄 할 내가 broker에 성공적으로 연결할 때마다 기대하고 메시지 onFailure 의도적으로 네트워크 연결을 끊은 경우와 같이 연결이 끊어진 경우 인쇄 할 동기 콜백입니다. 그러나 내가 broker에 연결할 때, onSuccess도 onFailur도 아무 것도 배출하지 않습니다. 그래서, 그들은 무엇을 위해 설계 되었습니까?

* Update_2_17_Dec_2014

I가 내가 유선/와이어가없는 네트워크를 통해 브로커에 연결하고 있다면, 그건 문제가 않습니다있는 용액에 우리를 이끌 수 문의? 그 동기 및 비동기 리스너의 동작이 바뀌겠습니까?

Updated_1_code :

MqttConnectOptions opts = getClientOptions(); 
     client = MQTTClientFactory.newClient(broker, port, clientID); 

     if (client != null) { 
      System.out.println("Client is not Null"); 
      client.setCallback(AsynchCallBack); 
      if (opts != null) { 
       iMQTTToken = client.connectWithResult(opts); 
       publishMSG(client, TOPIC,"010101".getBytes(), QoS, pub_isRetained); 
       iMQTTToken.setActionCallback(synchCallBack); 
       if (client.isConnected()) { 
        System.out.println("Client CONNECTED."); 
        publishMSG(client, TOPIC,"010101".getBytes(), QoS, pub_isRetained); 
       } 
      } 
     } 
    .... 
    .... 
    .... 
    .... 
IMqttToken iMQTTToken = new IMqttToken() { 

    @Override 
    public void waitForCompletion(long arg0) throws MqttException { 
     // TODO Auto-generated method stub 
     System.out.println("@waitForCompletion(): waiting " + (arg0 * 1000) + " seconds for connection to be established."); 
    } 

    @Override 
    public void waitForCompletion() throws MqttException { 
     // TODO Auto-generated method stub 
     System.out.println("@waitForCompletion(): waiting for connection to be established."); 
    } 

    @Override 
    public void setUserContext(Object arg0) { 
     // TODO Auto-generated method stub 

    } 

    @Override 
    public void setActionCallback(IMqttActionListener arg0) { 
     // TODO Auto-generated method stub 
     arg0.onSuccess(iMQTTToken); 
     //System.out.println(" " + arg0.onSuccess()); 
     //System.out.println(" " + arg0.onSuccess(iMQTTToken)); 
     iMQTTToken.setActionCallback(synchCallBack); 
    } 

    @Override 
    public boolean isComplete() { 
     // TODO Auto-generated method stub 
     return false; 
    } 

    @Override 
    public Object getUserContext() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public String[] getTopics() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public boolean getSessionPresent() { 
     // TODO Auto-generated method stub 
     return false; 
    } 

    @Override 
    public MqttWireMessage getResponse() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public int getMessageId() { 
     // TODO Auto-generated method stub 
     return 0; 
    } 

    @Override 
    public int[] getGrantedQos() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public MqttException getException() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public IMqttAsyncClient getClient() { 
     // TODO Auto-generated method stub 
     return null; 
    } 

    @Override 
    public IMqttActionListener getActionCallback() { 
     // TODO Auto-generated method stub 
     return null; 
    } 
}; 

IMqttActionListener synchCallBack = new IMqttActionListener() { 

    @Override 
    public void onSuccess(IMqttToken arg0) { 
     // TODO Auto-generated method stub 
     System.out.println("@onSuccess: Connection Successful."); 
    } 

    @Override 
    public void onFailure(IMqttToken arg0, Throwable arg1) { 
     // TODO Auto-generated method stub 
     System.out.println("@onFailure: Connection Failed."); 
     setViewEnableState(Bconnect, true); 
    } 
}; 

MqttCallback AsynchCallBack = new MqttCallback() { 

    @Override 
    public void messageArrived(String topic, MqttMessage msg) throws Exception { 
     // TODO Auto-generated method stub 
     System.out.println("@messageArrived: Message Delivered."); 
    } 

    @Override 
    public void deliveryComplete(IMqttDeliveryToken token) { 
     // TODO Auto-generated method stub 
     System.out.println("@deliveryComplete: Delivery Completed."); 
    } 

    @Override 
    public void connectionLost(Throwable thrw) { 
     // TODO Auto-generated method stub 
     System.out.println("@Connection Lost: Connection Lost."); 
     setViewEnableState(Bconnect, true); 
    } 
}; 

Newclient :

MqttConnectOptions opts = new MqttConnectOptions(); 
    opts.setCleanSession(CS); 
    opts.setKeepAliveInterval(KATimer); 
    HashMap<Integer, WILL> LWTData = WILLFactory.newWILL("LWT", "LWT MS".getBytes(), 1, false); 
    opts.setWill(LWTData.get(0).getWILLTopic(), 
      LWTData.get(0).getWILLPayLoad(), 
      LWTData.get(0).getWILLQoS(), 
      LWTData.get(0).isWILLRetained()); 

    client = MQTTClientFactory.newClient(IP, PORT, clientID); 

    if (client != null) { 
     System.out.println("client is not null"); 

     client.setCallback(AsynchCB); 
     IMqttToken token = client.connectWithResult(opts); 

     if (client.isConnected()) { 
      System.out.println("Client is Connected"); 

      token.setActionCallback(new IMqttActionListener() { 

       public void onSuccess(IMqttToken arg0) { 
        // TODO Auto-generated method stub 
        System.out.println("synchCB->@onSuccess(): Connection Successful"); 

        try { 
         client.subscribe(TOPIC, QoS); 
        } catch (MqttException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 
        try { 
         client.disconnect(); 
        } catch (MqttException e) { 
         // TODO Auto-generated catch block 
         e.printStackTrace(); 
        } 
       } 

       public void onFailure(IMqttToken arg0, Throwable arg1) { 
        // TODO Auto-generated method stub 
        System.out.println("synchCB->@onFailure(): Connection Failed"); 
       } 
      }); 
     }else { 
      System.out.println("client is not connected"); 
     } 
    }else { 
     System.out.println("client = null"); 
    } 

비동기 콜백 :

/** 
* Asynchronous Callback to inform the user about events that might happens Asynchronously. If it is not used, any pending 
* messages destined to the client would not be received. 
*/ 
private static MqttCallback AsynchCB = new MqttCallback() { 

    public void messageArrived(String topic, MqttMessage msg) throws Exception { 
     // TODO Auto-generated method stub 
     System.out.println("AsynchCB->@messageArrived(): "); 

     System.out.println("Topic: " + topic); 
     System.out.println("MSG: " + msg.toString()); 

    } 

    public void deliveryComplete(IMqttDeliveryToken arg0) { 
     // TODO Auto-generated method stub 
     System.out.println("AsynchCB->@deliveryComplete(): "); 
    } 

    public void connectionLost(Throwable arg0) { 
     // TODO Auto-generated method stub 
     System.out.println("AsynchCB->@connectionLost(): "); 
    } 
}; 

Answer 1

당신의 m 콜백을 처리하는 클라이언트가있는 achine은 발신 포트가 시스템의 방화벽에 의해 차단 될 수 있습니다.