(spring boot) 호출한 메소드가 계속 null에러를 발생시킵니다.

Question

mqtt로 수신받을 때마다 메시지를 db에 저장하는 간단한 프로그램을 만드는 중입니다. mqtt 클래스에서 db service 함수를 호출하여 사용하려는데 계속 null오류가 뜹니다.db관련 함수들은 test 했을때 오류없이 성공했습니다. 어디가 잘못된건지 잘 모르겠습니다.. 도와주시면 감사하겠습니다 ㅠ 오류 : MqttException (0) - java.lang.NullPointerException: Cannot invoke "com.WebSocketEx.chatting.service.lampService.registerLamp(com.WebSocketEx.chatting.domain.lampDTO)" because "this.lampService" is null lampServiceImpl.java:package com.WebSocketEx.chatting.service; import java.util.Collections; import java.util.List; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import com.WebSocketEx.chatting.domain.lampDTO; import com.WebSocketEx.chatting.mapper.LampMapper; @Service public class lampServiceImpl implements lampService{ @Autowired private LampMapper lampMapper; @Override public boolean registerLamp(lampDTO params) { int result = 0; result = lampMapper.insertLamp(params); return (result == 1) ? true : false; } @Override public List getLampList(String topic) { List lampList = Collections.emptyList(); //emptyList를 이용해 비어있는 리스드 선언 int lampTotalCnt = lampMapper.selectLampTotalCount(); if (lampTotalCnt > 0) { lampList = lampMapper.selectLampList(topic); //특정 토픽의 리스트 반환 } return lampList; } } mqtt클래스PahoDemo.java :package com.WebSocketEx.chatting.mqtt; import org.eclipse.paho.client.mqttv3.IMqttDeliveryToken; import org.eclipse.paho.client.mqttv3.MqttCallback; import org.eclipse.paho.client.mqttv3.MqttClient; import org.eclipse.paho.client.mqttv3.MqttException; import org.eclipse.paho.client.mqttv3.MqttMessage; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service; import org.springframework.web.socket.WebSocketSession; import com.WebSocketEx.chatting.domain.lampDTO; import com.WebSocketEx.chatting.service.lampService; import com.WebSocketEx.chatting.service.lampServiceImpl; @Component public class PahoDemo implements MqttCallback { MqttClient client; WebSocketSession session; @Autowired private lampService lampService; //db 저장 서비스 클래스 //mqtt 연결 public void doDemo() throws InterruptedException { try { client = new MqttClient("tcp://127.0.0.1:1883", "username"); // (serverURL,clientId) client.connect(); // 연결 client.setCallback(this); client.subscribe("deneb"); // "deneb" sub 구독 System.out.println("======="+"deneb"+" topic에 연결======="); } catch (MqttException e) { e.printStackTrace(); } } //전송 public void publish(String content) { MqttMessage message = new MqttMessage(); message.setPayload(content.getBytes()); // String -> MqttMessage 변환 try { client.publish("deneb", message); } catch (MqttException e) { e.printStackTrace(); } } //종료 public void disconnect(){ try { System.out.println("=========연결 종료========="); client.disconnect(); client.close(); } catch (MqttException e) { e.printStackTrace(); } } @Override public void connectionLost(Throwable cause) { // cause 연결이 끊어진 이유 // 이 메서드는 서버와의 연결이 끊어 질 때 호출됩니다. System.out.println("============================================== " + "mqtt 연결이 끊어졌습니다. 이유 : "+cause+ " =============================================="); } @Override public void messageArrived(String topic, MqttMessage message) throws Exception { // 이 메서드는 서버에서 메시지가 도착할 때 호출됩니다. client.publish System.out.println("pahoDemo가 받은메시지 : "+message); // -> 받은 메시지를 db에 저장 lampDTO params = new lampDTO(); params.setDeviceNum(1); params.setHumiAndTemp(message.toString()); params.setTopic("deneb"); lampService.registerLamp(params); //db 저장 함수 System.out.println("db저장"); } @Override public void deliveryComplete(IMqttDeliveryToken token) { // 메시지 전달이 완료되고 모든 승인이 수신되면 호출 } }

(spring boot) 호출한 메소드가 계속 null에러를 발생시킵니다.

0개의 답변

#mqtt 목록