구독자가 Mqtt 주제에서 비활성 상태 일 때 제작자가 보낸 모든 데이터를 얻는 방법 Java (보유하지 않거나 마지막 메시지가 아님)

Question

나는 온통 인터넷을 찾고 있습니다. 나는 cleansession "false"와 qos 1과 2를 설정하려고 시도했지만 아직 온라인에 올 때 구독자는 모든 콘텐츠를 얻지 못하고 있습니다. 도와주세요 ... 내 코드

Example.java (프로듀서)

public class Example extends PersonBean { 
public void hey(){ 
String clientId = MqttClient.generateClientId(); 
MemoryPersistence persistence = new MemoryPersistence(); 

    PersonBean pb=new PersonBean(); 
    for(int i=1;i<=5;i++){ 
     Gson gson = new Gson(); 

     Date dt=new Date(); 
     DateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss"); 
     String currentTime = df.format(dt); 
    pb.setId(i); 
    pb.setName("sai"); 
    pb.setEmail("s@g.com"); 
    pb.setAddress("hyderabad"); 
    pb.setCreatedOn(currentTime); 


    String jsonInString = gson.toJson(pb); 


     try { 
      String broker = "tcp://localhost:1883"; 
      String topicName = "test/mqtt"; 
      int qos = 2; 

    MqttClient mqttClient = new MqttClient(broker,clientId); 
      MqttConnectOptions connOpts = new MqttConnectOptions(); 
      connOpts.setCleanSession(false); 
      mqttClient.connect(connOpts); 

      MqttMessage message = new MqttMessage(jsonInString.getBytes()); 

      message.setQos(qos); 
    message.setRetained(true); 


      MqttTopic topic2 = mqttClient.getTopic(topicName); 
topic2.publish(message); 

     mqttClient.disconnect(); 
     } catch (MqttException me) { 
      System.out.println("reason " + me.getReasonCode() + " - msg " 
        + me.getMessage() + "- loc " + me.getLocalizedMessage() 
        + " - cause " + me.getCause() + "- exception " + me); 

     } 


    }} 

    public static void main(String[] args) { 
    Example ex=new Example(); 
    ex.hey(); 
}} 

내

Subscriber.java

public class SubcriberExample implements MqttCallback{ 

MqttClient client; 
public void doDemo() { 
    try { 
     client = new MqttClient("tcp://192.168.4.189:1883", "Sending"); 
     client.connect(); 
     client.setCallback(this); 
     client.subscribe("test/mqtt"); 



    } catch (MqttException e) { 
     e.printStackTrace(); 
    } 
} 

public static void main(String args[]){ 
    SubcriberExample se=new SubcriberExample(); 
    se.doDemo(); 
} 

@Override 
public void connectionLost(Throwable arg0) { 
    // TODO Auto-generated method stub 
    System.out.println("connection lost...."); 
} 

@Override 
public void deliveryComplete(IMqttDeliveryToken arg0) { 
    // TODO Auto-generated method stub 

} 

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

Answer 1

당신은에있어입니다 올바른 트랙, 게시 된 메시지는 개최 자격이되기 위해 QoS1/2 여야 함 (오프라인 가입자의 경우) 오프라인 대기열에 있습니다.

그러나 위의 코드에서 문제는 구독자에있는 것 같습니다. MQTT 등록자가 오프라인 메시지를 수신 할 수 있으려면, 지속적 세션이 있어야합니다. 나는. 가입자는 clean session = false로 연결해야합니다.