20220901 [Spring Boot, MQTT]

등록/수정/삭제 등 데이터 변경시
MQTT를 이용하여 발행(publish)과 구독(subscribe)을 통해 실시간으로 정보 수신

새 프로젝트 network_exam 생성 후
물품관리 서버구현 파일 복사하여 그대로 가져오고 추가로 itemview 와 broker만 생성

🔌 서버연결 및 통신

MQTT는 발행(publish)과 구독(subscribe)을 통해 데이터를 주고 받는다
publish는 데이터를 보내는 것, subscribe는 데이터를 받는 것이다

• 구독(subscribe)을 통한 실시간 정보변화 감지 수신
  MqttCallback은 사용자가 전달하는 정보를 실시간 감지한다
  ItemView에서 ItemMqttClient를 구독subscribe했기 때문에 데이터 변화가 실시간으로 감지 가능하다
  ItemMqttClient의 messageArrived은 메세지 수신시 자동으로 실행되며 부모인 MqttCallback을 상속implements받은 메서드이다
• MQTT에서 데이터 발송(publish)
  ItemMqttClient의 sendMessage는 실시간 감지와 별개로 진행된다
  ItemMqttClient 에서 sendMessage는 MQTT에서 데이터 발송publish시 실행된다
  ➡️ ex) ItemMqttClient에서 TERMNAL에 메세지 발송

---

📠 실시간 정보변화 감지(subscribe)

1. app.java에서 ItemView.java 실행한다
2. ItemView.java가 ItemMqttClient.java 실행한다
   이때 ItemView는 자신의 객체this를 ItemMqttClient에게 전달해 준다
   ⚙️ ItemMqttClient에서 나중에printitem()을 호출 할 수 있게 하기 위해 주는 것!
3. 사용자가 보낸 메시지를 MqttCallback이 감지하여 messageArrived를 실행한다
   
4. messageArrived는 ItemView에서 출력하기 위해 printitem()을 호출 해야한다
   ➡️ printitem()을 호출을 위해 생성자에 ItemView의 객체인 itemObject = obj;를 생성한다
5. messageArrived는 printItem()을 이용해 ItemView.java로 topic과 msg를 보낸다
   ➡️ itemObject.printItem( topic, msg );
6. ItemView.java의 printItem메서드는 topic과 msg를 출력한다

---

📬 발행(publish)과 구독(subscribe)

📁 app.java

출력은 ItemView에서 실행
➡️ app.java 실행시 ItemView가 실행 됨

import com.example.view.ItemView;

public class App 
{
    public static void main( String[] args )
    {
        new ItemView();
    }
}

📁 broker/ItemMqttClient.java

• MqttCallback 를 상속 받아 오버라이딩하여 사용한다 = implements MqttCallback
  ➡️ implements : 부모는 선언만 하며, 반드시 자식이 부모의 정의를 오버라이딩해서 사용한다
  🌎 참고 extends, implements의 차이
• 한글 출력 설정시 "UTF-8" 사용
  
  String msg = new String( message.getPayload(), "EUC-KR" );
  🟥 출력시 한글이 깨져서 출력된다
  String msg = new String( message.getPayload(), "UTF-8" );
  🟦 한글이 깨짐없이 출력됨

1. 웹서버 브로커 설정

// 웹서버 브로커 설정시 => ws://127.0.0.1:1884, tcp://127.0.0.1.1883
    private String broker = "tcp://1.234.5.158:11883";
    private String clientId = "db207_" + System.currentTimeMillis();

    private String userid = "ds606";
    private String password = "ds606";

    // 전송되는 메시지를 보관하는 방법
    private MemoryPersistence persistence = new MemoryPersistence();
    private MqttAsyncClient client = null;

2. 데이터 출력이 이루어질 ItemView의 printitem() 호출 위해 itemObject 생성

// ItemView 호출 가능한 itemobject
    private ItemView itemObject;

3. MQTT 접속을 위한 생성자 생성

// 생성자 생성
    public ItemMqttClient(ItemView obj) {
        itemObject = obj;
        try {
            client = new MqttAsyncClient(broker, clientId, persistence);

            MqttConnectOptions options = new MqttConnectOptions();
            options.setUserName(userid);
            options.setPassword(password.toCharArray());
            options.setCleanSession(true);

            client.connect(options);
            client.setCallback(this); // 1. 객체를 전달함.

            System.out.println(this.client);// 접속객체
            Thread.sleep(1000);
            System.out.println("접속성공");
        } catch (Exception e) {
            System.out.println("접속실패");
            e.printStackTrace();
        }
    }

4. 구독하기/구독해제/메시지보내기 생성

// 구독하기
    public void subscribe() {
        try {
            client.subscribe("/ds207/#", 0);
            System.out.println("구독설정 성공");
        } catch (MqttException e) {
            e.printStackTrace();
            System.out.println("구독설정 실패");
        }
    }

    // 구독해제
    public void unSubscribe() {
        try {
            client.unsubscribe("/ds207/#");
            System.out.println("구독해제 성공");
        }
        catch(Exception e){
            e.printStackTrace();
            System.out.println("구독해제 실패");
        }
    }

    // 메시지보내기
    public void sendMessage(String msg) {
        try {
            MqttMessage message = new MqttMessage();
            message.setQos(0);
            message.setPayload( msg.getBytes() );
            if(client != null) {
                client.publish("/ds207/test207", message);
            }
        }
        catch(Exception e){
            e.printStackTrace();
            System.out.println("메시지 보내기 실패");
        }
    }

5. implements MqttCallback 에 대한 오버라이드 생성

• messageArrived 오버라이드 작성시 MqttMessage ⇒ String으로 변경해주어야 한다
  아래에서 확인 해보면 getPayload() 는 byte형태의 []배열로 오기 때문에 String으로 변경해준다
  

@Override
    public void connectionLost(Throwable arg0) {
        // 서버 연결이 끊겼을때
        System.out.println("서버 연결 끊겼을 때");

    }

    @Override
    public void messageArrived(String topic, MqttMessage message) throws Exception {
        // 메세지가 도착했을때
        System.out.println("메세지가 왔을 때");
        // MqttMessage => String으로 변경
        String msg = new String( message.getPayload(), "UTF-8" ); //한글이 깨짐없이 출력됨

        // System.out.println(topic + ", " + msg); => itemview에서 출력해야함

        // itemobject.printItem 사용하여
        // printItem안에 데이터 전송해서 view쪽에서 출력!

        // String -> JSON parser
        itemObject.printItem( topic, msg );
    }

    @Override
    public void deliveryComplete(IMqttDeliveryToken arg0) {
        // 내가 전송하는 메시지를 정확히 전송 완료 했을때
        System.out.println("메세지 전송을 완료 했을 때");
    }

---

📁 view/ItemView.java

구독 및 출력
1. ItemView의 객체를 ItemMqttClient에게 전달해줌
➡️ 나중에 printItem() 사용을 위해 ItemMqttClient에게 자신의 객체this를 ItemMqttClient에게 전달
2. 구독하기
➡️ obj.subscribe();

package com.example.view;

import com.example.broker.ItemMqttClient;

public class ItemView {

    public ItemView() {
        // 1. ItemMqttClient 호출
        // 나중에 printItem 쓰기 위해 ItemView의 객체를 ItemMqttClient에게 전달
        ItemMqttClient obj = new ItemMqttClient(this);

        // 2. 구독하기
        obj.subscribe();
    }

    // 변경내용의 출력은 여기서
    public void printItem(String topic, String msg){
        System.out.println(topic + "," + msg);
    }
}

📁 AppTest.java

AppTest에서 사용자가 전송한 메세지는 MqttCallback이 감지하여 messageArrived가 받는다

...

public class AppTest 
{
    // 아이템 서비스 객체 생성
    ItemService iService = new ItemServiceImpl();

    // 네트워크 mqtt 객체 생성
    ItemMqttClient mqttClient = new ItemMqttClient(null);

    @Test
    public void insert()
    {   //물품 등록
        Item item = new Item();
        item.setNo(17L);
        item.setName("err");
        item.setPrice(8860L);

        // 서비스를 통해 추가 insertItem
        iService.insertItem(item);

        // JSON문서로 변경하여 sendMessage에 보내기
        JSONObject jobj = new JSONObject();
        jobj.put("type", 1);
        mqttClient.sendMessage(jobj.toString());
        mqttClient.sendMessage( item.getNo() + "번 항목을 추가했습니다");
        

    }

    @Test
    public void update()
    { //물품 수정
        Item item = new Item(6L, "MMM", 1500L, null);

        // 서비스 호출하여 수정 updateItem
        iService.updateItem(item);

        // json문서로 변경하여 보내기
        JSONObject jobj = new JSONObject();
        jobj.put("type", "update");
        mqttClient.sendMessage(jobj.toString());

    }

    @Test
    public void delete()
    { // 물품 삭제
        Item item = new Item();
        item.setNo(15L);

        iService.deleteItem(item);

		// json문서로 변경하여 보내기
        JSONObject jobj = new JSONObject();
        jobj.put("type", "delete");
        // mqttClient.sendMessage(jobj.toString());
        mqttClient.sendMessage(item.getNo() + "번 항목을 삭제했습니다");

    }
}