Kaynağa Gözat

이벤트 수신 포트 8098 -> 2222 포트로 수정 (수신 포트는 임시 포트)

pangs 6 yıl önce
ebeveyn
işleme
884b14866f

+ 2 - 1
src/main/java/com/icontrols/kakao/common/SERVERINFO.java

@@ -10,7 +10,8 @@ public class SERVERINFO {
 	public static final int clientNewPort = 10002;
 	public static final int clientNewPort = 10002;
 
 
 	// 월패드에서 수신되는 데이터를 처리 하기 위한 소켓 포트
 	// 월패드에서 수신되는 데이터를 처리 하기 위한 소켓 포트
-	public static final int WalladReceivePort = 8098;
+//	public static final int WalladReceivePort = 8098;
+	public static final int WalladReceivePort = 2222;
 
 
 	public static final String DanjiServerIP = "10.0.1.1";
 	public static final String DanjiServerIP = "10.0.1.1";
 	public static final int DanjiServerPort = 10000;
 	public static final int DanjiServerPort = 10000;

+ 1 - 1
src/main/java/com/icontrols/kakao/controller/KakaoDanziController.java

@@ -56,7 +56,7 @@ public class KakaoDanziController {
 			String requestId = (String)params.get("id");
 			String requestId = (String)params.get("id");
 			String requestType = (String) params.get("type");
 			String requestType = (String) params.get("type");
 			String authorization = (String) params.get("authorization");
 			String authorization = (String) params.get("authorization");
-			String body = params.get("body").toString();
+			String body = params.containsKey("body")?params.get("body").toString():"";
 			
 			
 			if(body.length() > 255) body = body.substring(0, 255);
 			if(body.length() > 255) body = body.substring(0, 255);
 			
 			

+ 2 - 1
src/main/java/com/icontrols/kakao/socket/wallpad/RecieveiMapMultiSocket.java

@@ -32,6 +32,7 @@ public class RecieveiMapMultiSocket {
 		logger.info("월패드 수신 포트 :" + SERVERINFO.WalladReceivePort);
 		logger.info("월패드 수신 포트 :" + SERVERINFO.WalladReceivePort);
 		logger.info("****************************************");
 		logger.info("****************************************");
 
 
+		
 		ServerSocket server = null;
 		ServerSocket server = null;
 		long connectCount = 0;
 		long connectCount = 0;
 		try {
 		try {
@@ -55,7 +56,7 @@ public class RecieveiMapMultiSocket {
 				String ip 		= ia.getHostAddress(); 						// 접속된 원격 Client IP
 				String ip 		= ia.getHostAddress(); 						// 접속된 원격 Client IP
 
 
 				connectCount += 1; 											// 접속자수 카운트 증가
 				connectCount += 1; 											// 접속자수 카운트 증가
-				logger.info(" Connect Count : "+ connectCount + " , 접속-Local Port: " + port, " , Client IP: " + ip);
+				logger.info(" Connect Count : "+ connectCount + " , 접속-Local Port: " + port + " , Client IP: " + ip);
 
 
 				if (connectCount > 2000000000) connectCount = 0;			// [질문]- 아직 초기화 하는 이유를 모르겠슴돠.. int의 MAX_VALUE에 근접해서 인가요? ? ? ? ? .황.
 				if (connectCount > 2000000000) connectCount = 0;			// [질문]- 아직 초기화 하는 이유를 모르겠슴돠.. int의 MAX_VALUE에 근접해서 인가요? ? ? ? ? .황.
 																			// [답변]- 
 																			// [답변]- 

+ 1 - 7
src/main/java/com/icontrols/kakao/socket/wallpad/ThreadServerHandler.java

@@ -42,7 +42,6 @@ public class ThreadServerHandler extends Thread {
 	private static final Logger logger = LoggerFactory.getLogger(ThreadServerHandler.class);
 	private static final Logger logger = LoggerFactory.getLogger(ThreadServerHandler.class);
 
 
 	private Socket connectedClientSocket;					// 클라이언트와 연결된 소켓 객체
 	private Socket connectedClientSocket;					// 클라이언트와 연결된 소켓 객체
-	String XMLHeader;										// 사용 하지는 않지만 XML의 Header 역할을 하는 String --> 추후에도 사용하지 않으면 삭제 예정 
 	
 	
 	private String strRcvMSG;								//  입력 받은 XML String 
 	private String strRcvMSG;								//  입력 받은 XML String 
 	private Document doc;									// 
 	private Document doc;									// 
@@ -60,11 +59,6 @@ public class ThreadServerHandler extends Thread {
 		// Client와 통신할 객체를 초기값으로 받아 할당합니다.
 		// Client와 통신할 객체를 초기값으로 받아 할당합니다.
 		this.connectedClientSocket = connectedClientSocket;
 		this.connectedClientSocket = connectedClientSocket;
 		this.newDanjiServerNoticeUpdate = server;
 		this.newDanjiServerNoticeUpdate = server;
-		StringBuffer sb = new StringBuffer();
-		
-		sb.append("<?xml version=\"1.0\" encoding=\"utf-8\"?>\r\n")
-		.append("	<imap ver = \"1.0\" address = \"10.0.1.1\" sender = \"단지서버\">\r\n");
-		XMLHeader = sb.toString();
 	}
 	}
 
 
 	public void run() {
 	public void run() {
@@ -268,7 +262,7 @@ public class ThreadServerHandler extends Thread {
 						
 						
 						if(code == KAKAO_RESULT.SUCCESS) {
 						if(code == KAKAO_RESULT.SUCCESS) {
 							logger.info("[EVENT SUCCESS] - " + message);
 							logger.info("[EVENT SUCCESS] - " + message);
-						}else {
+						} else {
 							logger.error("[EVENT ERROR] - " + message);
 							logger.error("[EVENT ERROR] - " + message);
 						}
 						}
 					}
 					}