웹소켓 무한 에러...

Question

안녕하세요, 웹소켓 통신을 시도하고 있는 초짜입니다... --__주말 내내 키보드 두들겨봤는데 안돼서, 이곳 고수님들을 찾아왔습니다.. ㅠㅠ저는 지금 ec2 인스턴스 <-> 로컬 환경 간의 웹소켓 통신을 시도하고 있습니다.ec2에는 파이썬 환경에서 websockets 라는 라이브러리로 웹소켓 서버를 만들어 열었고요, websockets.serve(func, '0.0.0.0', 3000) 해줬고 보안 그룹으로 0.0.0.0 3000 주소 열어줬고로컬에는 리액트js로 웹 하나 파서 WebSocket 객체를 만들었습니다. ec2 퍼블릭 주소랑 80포트로 웹소켓 열었습니다.근데 자꾸... 클라이언트쪽 웹을 보면 Websocket Connection to ws://... failed 에러가 뜹니다 ㅠㅠ 보안그룹도 열어줬고 ec2 주소랑 포트번호도 제대로 써줬고 ec2쪽이랑 웹 쪽 둘다 socket.io가 아니라 WebSocket 으로 써줬는데 왜 currentTarget readyState가 3인지, 연결이 왜 안되는지 모르겠네요, 혹시 제가 빠트린 부분이 있을까요???? ㅠㅠㅠ 감사합니다!!이건 ec2 안에 있는 파이썬 코드입니다. async def process_data(): global data_bundle global connected_clients testResult = await post_data(data_bundle) if connected_clients: await connected_clients.send('test!!!!') print("sended!!") else: pass def run_async(func): asyncio.run(func()) def on_connect(client, userdata, flags, rc): if rc == 0: print("connected OK!!") else: print("Bad connection!!! Returned code=", rc) def on_disconnect(client, userdata, flags, rc=0): print("disconnected!!!") def on_subscribe(client, userdata, mid, granted_qos): print("subscribed!!") def on_message(client, userdata, msg): threading.Thread(target=run_async, args=(process_data, )).start() # 새 스레드에서 실행 def start_client(): client = mqtt.Client() client.on_connect = on_connect client.on_disconnect = on_disconnect client.on_subscribe = on_subscribe client.on_message = on_message client.tls_set(CA_ROOT_CERT_FILE, certfile=THING_CERT_FILE, keyfile=THING_PRIVATE_KEY, cert_reqs=ssl.CERT_REQUIRED, tls_version=ssl.PROTOCOL_TLSv1_2, ciphers=None) client.connect(MQTT_HOST, MQTT_PORT) client.subscribe(MQTT_TOPIC, 1) client.loop_forever() async def echo(websocket, path): global connected_clients connected_clients = websocket print("클라이언트가 연결되었습니다.") # 연결된 클라이언트를 알림 try: while True: data = await websocket.recv() # 클라이언트로부터 메시지를 대기한다. print("receive : " + data) await websocket.send("ws_srv send data = " + data) except: print("클라이언트와의 연결이 끊어졌습니다.") # 연결 끊김 알림 async def start_server(): async with websockets.serve(echo, '0.0.0.0', 3000): print("웹소켓 서버가 열렸습니다.") await asyncio.Future() async def starter(): await asyncio.gather( asyncio.to_thread(start_client), # MQTT 클라이언트를 스레드에서 실행 start_server() ) asyncio.run(starter())그리고 이건 리액트 코드입니다. import { useCallback, useRef, useState } from "react"; export function useConnectSocket() { const [isConnected, setIsConnected] = useState(false); const socketRef = useRef(null); const dataRef = useRef({ }); const connectWebSocket = useCallback(() => { socketRef.current = new WebSocket( `ws://ec2ipv4publicDNS.amazonaws.com:80` ); }, []); const handleWebSocketOpen = useCallback(() => { console.log("웹소켓이 열렸습니다."); setIsConnected(true); socketRef.current?.send("클라이언트가 보내는 메세지"); }, []); const handleWebSocketMessage = useCallback((e: MessageEvent) => { console.log(e.data); }, []); const handleWebSocketClose = useCallback((e: CloseEvent) => { // connectWebSocket(); console.log("웹소켓을 닫았습니다."); socketRef.current = null; }, []); const handleWebSocketError = useCallback((e: any) => { connectWebSocket(); console.error(e); }, []); const startWebSocket = useCallback(() => { connectWebSocket(); if (socketRef.current) { socketRef.current.onopen = handleWebSocketOpen; socketRef.current.onmessage = handleWebSocketMessage; socketRef.current.onclose = handleWebSocketClose; socketRef.current.onerror = handleWebSocketError; } }, [ connectWebSocket, handleWebSocketOpen, handleWebSocketMessage, handleWebSocketClose, handleWebSocketError, ]); return { socketRef, startWebSocket, isConnected, dataRef }; }

2948284 · Answer

로컬에 서버를 띄울땐 정상인가요?원격 서버로 Telnet시 정상인가요?

코딩하는 두루미 · Answer

EC2(Https) <-> 로컬(Http) 아닌가요?http와 https는 직접적인 통신이 어렵습니다.

웹소켓 무한 에러...

2개의 답변

Q&A 목록