이 가이드는 Python에서 WebSocket 프록시 서버를 만드는 방법을 알려줍니다.
서버가 수행할 작업은 다음과 같습니다.
- 클라이언트 신원 확인: 클라이언트 연결을 허용하기 전에 각 클라이언트에 고유한 "사용자 키(API 키)"가 있는지 확인합니다.
- 다른 WebSocket에 연결: 서버가 별도의 WebSocket 서버에 연결됩니다.
- 릴레이 메시지: 서버는 연결된 WebSocket에서 메시지를 수신하여 확인된 모든 클라이언트에 보냅니다.
시작하기 전에:
- Python 3.6 이상 버전을 설치했는지 확인하세요. WebSocket에는 Python 3.6 이상이 필요합니다.
- WebSockets 라이브러리 설치: 터미널에서 다음 명령을 사용하여 설치할 수 있습니다.
pip install websockets
1. 시작하기
- 프로젝트를 위한 새 폴더를 만듭니다.
- 폴더 안에 새 Python 파일을 만들고 이름을 'websocket_proxy_server.py'로 지정합니다. 이 파일에는 서버의 모든 코드가 들어 있습니다.
2. WebSocket 서버 생성
- 필요한 라이브러리를 가져옵니다. 이전에 설치한 라이브러리가 필요합니다.
- 서버의 기본 구조를 구축하세요. WebSockets 라이브러리를 사용하여 서버의 기반을 만드세요.
import asyncio import websockets import json class WebSocketProxy: def init(self, source_url, symbols): self.source_url = source_url self.clients = set() self.symbols = symbols self.valid_user_key = "yourValidUserKey" # Single valid user key for authentication async def on_open(self, ws): print("Connected to source") symbols_str = ",".join(self.symbols.keys()) init_message = f"{{"userKey":"your_api_key", "symbol":"{symbols_str}"}}" await ws.send(init_message)
3. 클라이언트 연결 및 확인
- 서버가 클라이언트의 연결을 허용하도록 모두 설정되어 있는지 확인하세요.
- 각 고객의 신원을 확인하려면 검사를 추가하세요. 클라이언트가 연결을 시도하면 서버는 "사용자 키"를 요청해야 합니다. 올바른 키를 가진 클라이언트만 연결이 허용됩니다.
async def client_handler(self, websocket, path): try: # Wait for a message that should contain the authentication key auth_message = await asyncio.wait_for(websocket.recv(), timeout=10) auth_data = json.loads(auth_message) user_key = auth_data.get("userKey") if user_key == self.valid_user_key: self.clients.add(websocket) print(f"Client authenticated with key: {user_key}") try: await websocket.wait_closed() finally: self.clients.remove(websocket) else: print("Authentication failed") await websocket.close(reason="Authentication failed") except (asyncio.TimeoutError, json.JSONDecodeError, KeyError): print("Failed to authenticate") await websocket.close(reason="Failed to authenticate")
4. 소스에 연결하고 메시지 공유
- 서버를 원래 WebSocket에 계속 연결하는 기능을 만듭니다.
- 이 기능은 원래 WebSocket에서 받은 메시지를 성공적으로 확인된 모든 클라이언트에 자동으로 보내야 합니다.
async def source_handler(self): async with websockets.connect(self.source_url) as websocket: await self.on_open(websocket) async for message in websocket: await self.broadcast(message) async def broadcast(self, message): if self.clients: await asyncio.gather(*(client.send(message) for client in self.clients))
5. 서버 시작
- 서버를 시작하고 연결을 수신하는 함수를 만듭니다.
- WebSocket 프록시 서버를 시작하여 이 함수를 실행하는 코드를 추가하세요.
def run(self, host="localhost", port=8765): start_server = websockets.serve(self.client_handler, host, port) asyncio.get_event_loop().run_until_complete(start_server) asyncio.get_event_loop().run_until_complete(self.source_handler()) asyncio.get_event_loop().run_forever() if name == "main": symbols = {"EURUSD": {}, "GBPUSD": {}, "USDJPY": {}, "AUDUSD": {}, "USDCAD": {}} source_url = "ws://example.com/source" proxy = WebSocketProxy(source_url, symbols) proxy.run()
요약하면
Python 기반 WebSocket 프록시 서버를 성공적으로 개발하셨습니다. 이 서버는 클라이언트 ID를 인증하고, 지정된 데이터 소스에 대한 지속적인 연결을 유지하며, 소스에서 받은 메시지를 확인된 모든 클라이언트에 효과적으로 배포할 수 있습니다. 이 기능은 단일 출처에서 다양한 사용자 기반으로 데이터를 안전하고 즉각적으로 배포해야 하는 애플리케이션에 매우 귀중한 것으로 입증되었습니다.
다음 단계
최적의 성능과 안정성을 보장하려면 철저한 서버 테스트가 중요합니다. 연결 및 메시지 전송이 적절하게 처리되는지 확인합니다. 효율성을 높이려면 로드 밸런싱 메커니즘을 구현하고 연결 헤더를 사용자 지정하는 것이 좋습니다. 마지막으로, 장기간 네트워크 연결을 수용하도록 특별히 설계된 클라우드 서비스 등 프로덕션 배포에 적합한 환경에 서버를 배포하는 것이 좋습니다.
또한 당사 웹사이트에 원래 게시된 튜토리얼인 Python 프록시를 사용하여 Forex WebSocket 확장
도 살펴보시기 바랍니다.위 내용은 Python 프록시를 사용하여 확장 가능한 Forex WebSocket 구현의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

이 기사에서는 HTML을 구문 분석하기 위해 파이썬 라이브러리 인 아름다운 수프를 사용하는 방법을 설명합니다. 데이터 추출, 다양한 HTML 구조 및 오류 처리 및 대안 (SEL과 같은 Find (), find_all (), select () 및 get_text ()와 같은 일반적인 방법을 자세히 설명합니다.

Linux 터미널에서 Python 버전을 보려고 할 때 Linux 터미널에서 Python 버전을 볼 때 권한 문제에 대한 솔루션 ... Python을 입력하십시오 ...

파이썬 객체의 직렬화 및 사막화는 사소한 프로그램의 주요 측면입니다. 무언가를 Python 파일에 저장하면 구성 파일을 읽거나 HTTP 요청에 응답하는 경우 객체 직렬화 및 사태화를 수행합니다. 어떤 의미에서, 직렬화와 사제화는 세계에서 가장 지루한 것들입니다. 이 모든 형식과 프로토콜에 대해 누가 걱정합니까? 일부 파이썬 객체를 지속하거나 스트리밍하여 나중에 완전히 검색하려고합니다. 이것은 세상을 개념적 차원에서 볼 수있는 좋은 방법입니다. 그러나 실제 수준에서 선택한 직렬화 체계, 형식 또는 프로토콜은 속도, 보안, 유지 보수 상태 및 프로그램의 기타 측면을 결정할 수 있습니다.

Python의 통계 모듈은 강력한 데이터 통계 분석 기능을 제공하여 생물 통계 및 비즈니스 분석과 같은 데이터의 전반적인 특성을 빠르게 이해할 수 있도록 도와줍니다. 데이터 포인트를 하나씩 보는 대신 평균 또는 분산과 같은 통계를보고 무시할 수있는 원래 데이터에서 트렌드와 기능을 발견하고 대형 데이터 세트를보다 쉽고 효과적으로 비교하십시오. 이 튜토리얼은 평균을 계산하고 데이터 세트의 분산 정도를 측정하는 방법을 설명합니다. 달리 명시되지 않는 한,이 모듈의 모든 함수는 단순히 평균을 합산하는 대신 평균 () 함수의 계산을 지원합니다. 부동 소수점 번호도 사용할 수 있습니다. 무작위로 가져옵니다 수입 통계 Fracti에서

이 기사는 딥 러닝을 위해 텐서 플로와 Pytorch를 비교합니다. 데이터 준비, 모델 구축, 교육, 평가 및 배포와 관련된 단계에 대해 자세히 설명합니다. 프레임 워크, 특히 계산 포도와 관련하여 주요 차이점

이 튜토리얼은 간단한 나무 탐색을 넘어서 DOM 조작에 중점을 둔 아름다운 수프에 대한 이전 소개를 바탕으로합니다. HTML 구조를 수정하기위한 효율적인 검색 방법과 기술을 탐색하겠습니다. 일반적인 DOM 검색 방법 중 하나는 EX입니다

이 기사는 Numpy, Pandas, Matplotlib, Scikit-Learn, Tensorflow, Django, Flask 및 요청과 같은 인기있는 Python 라이브러리에 대해 설명하고 과학 컴퓨팅, 데이터 분석, 시각화, 기계 학습, 웹 개발 및 H에서의 사용에 대해 자세히 설명합니다.

이 기사는 Python 개발자가 CLIS (Command-Line Interfaces) 구축을 안내합니다. Typer, Click 및 Argparse와 같은 라이브러리를 사용하여 입력/출력 처리를 강조하고 CLI 유용성을 향상시키기 위해 사용자 친화적 인 디자인 패턴을 홍보하는 세부 정보.


핫 AI 도구

Undresser.AI Undress
사실적인 누드 사진을 만들기 위한 AI 기반 앱

AI Clothes Remover
사진에서 옷을 제거하는 온라인 AI 도구입니다.

Undress AI Tool
무료로 이미지를 벗다

Clothoff.io
AI 옷 제거제

AI Hentai Generator
AI Hentai를 무료로 생성하십시오.

인기 기사

뜨거운 도구

스튜디오 13.0.1 보내기
강력한 PHP 통합 개발 환경

맨티스BT
Mantis는 제품 결함 추적을 돕기 위해 설계된 배포하기 쉬운 웹 기반 결함 추적 도구입니다. PHP, MySQL 및 웹 서버가 필요합니다. 데모 및 호스팅 서비스를 확인해 보세요.

드림위버 CS6
시각적 웹 개발 도구

안전한 시험 브라우저
안전한 시험 브라우저는 온라인 시험을 안전하게 치르기 위한 보안 브라우저 환경입니다. 이 소프트웨어는 모든 컴퓨터를 안전한 워크스테이션으로 바꿔줍니다. 이는 모든 유틸리티에 대한 액세스를 제어하고 학생들이 승인되지 않은 리소스를 사용하는 것을 방지합니다.

PhpStorm 맥 버전
최신(2018.2.1) 전문 PHP 통합 개발 도구
