수신모듈 추가

@@ -4,6 +4,7 @@ import numpy as np
 from queue import Queue
 from queue import Queue
 from _thread import *
 from _thread import *
 enclose_q = Queue()
 enclose_q = Queue()
+recv_enclose_q = Queue()
 import time
 import time
 def filter_img(img):
 def filter_img(img):
     #이미지의 RGB값을 분석하여 찾는 실내 Tag가 맞는지 판별
     #이미지의 RGB값을 분석하여 찾는 실내 Tag가 맞는지 판별
@@ -30,9 +31,6 @@ def bboxes(inp):
     img = inp
     img = inp
     start = time.time()
     start = time.time()
     curTime = time.time()
     curTime = time.time()
-    # img2gray = cv2.imread(fname,0)
-    # img = cv2.namedWindow(img,cv2.WINDOW_NORMAL)
-    # img = cv2.resizeWindow(img,600,600)
     img_final = inp
     img_final = inp
     img2gray = cv2.cvtColor(inp, cv2.COLOR_BGR2GRAY) #GRAY Image 8bit per pixel
     img2gray = cv2.cvtColor(inp, cv2.COLOR_BGR2GRAY) #GRAY Image 8bit per pixel
     ret, mask = cv2.threshold(img2gray, 180, 255, cv2.THRESH_BINARY) #threshold : distinguish background, object
     ret, mask = cv2.threshold(img2gray, 180, 255, cv2.THRESH_BINARY) #threshold : distinguish background, object
@@ -58,7 +56,7 @@ def bboxes(inp):
             continue
             continue
     return cropped
     return cropped
 
 
-def threaded(Client_socket, addr, queue):
+def send_threaded(Client_socket, addr, queue):
     print("Connected by : ", addr[0], " : ", addr[1])
     print("Connected by : ", addr[0], " : ", addr[1])
     while True:
     while True:
         try :
         try :
@@ -73,7 +71,6 @@ def threaded(Client_socket, addr, queue):
             print("Disconnected")
             print("Disconnected")
     Client_socket.close()
     Client_socket.close()
 
 
-
 def webcam(queue):
 def webcam(queue):
     capture = cv2.VideoCapture(0)
     capture = cv2.VideoCapture(0)
     while True:
     while True:
@@ -91,23 +88,48 @@ def webcam(queue):
         key = cv2.waitKey(1)
         key = cv2.waitKey(1)
         if key == 27:
         if key == 27:
             break
             break
+def recvall(sock, count):
+    # 바이트 문자열
+    buf = b''
+    while count:
+        newbuf = sock.recv(count)
+        if not newbuf: return None
+        buf += newbuf
+        count -= len(newbuf)
+    return buf
 
 
 if __name__ == '__main__':
 if __name__ == '__main__':
-    HOST = '127.0.0.1'
-    PORT = 9999
+    SEND_HOST = '127.0.0.1' #CORE CLOUD
+    SEND_PORT = 9999
 
 
     server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
     server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
     server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-    server_socket.bind((HOST, PORT))
+    server_socket.bind((SEND_HOST, SEND_PORT))
     server_socket.listen()
     server_socket.listen()
 
 
+    RECV_HOST = '127.0.0.1' #CORE CLOUD
+    RECV_PORT = 9998
+
+    recv_server_socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
+    recv_server_socket.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
+    recv_server_socket.bind((RECV_HOST, RECV_PORT))
+    recv_server_socket.listen()
+
     print('server start')
     print('server start')
 
 
     start_new_thread(webcam, (enclose_q,))
     start_new_thread(webcam, (enclose_q,))
-
     while True:
     while True:
         print('wait')
         print('wait')
 
 
         client_socket, addr = server_socket.accept()
         client_socket, addr = server_socket.accept()
-        start_new_thread(threaded, (client_socket, addr, enclose_q,))
+        start_new_thread(send_threaded, (client_socket, addr, enclose_q,)) #전처리 데이터 송신
+        conn,addr = recv_server_socket.accept() #수신 대기
+        if(conn): 
+            length = recvall(conn, 16)
+            stringData = recvall(conn, int(length))
+            data = np.fromstring(stringData, dtype = 'uint8') #주행정보 수신
+            if(conn): #연결 끊어질 경우 loop 탈출
+                break
+        else:
+            pass
     server_socket.close()
     server_socket.close()