기본 콘텐츠로 건너뛰기

MQTT subscribe - Wildcard

MQTT를 사용하다보면 여러개의 topic 을 동시에 가입해야할 경우가 있는데

가령 대화방의 경우 같은 방에 있는데 누가 메시지를 보냈는지 알아야하는데 subscribe한 top에 들어온 client ID 를 알 수는 없을 때 사용자 별로 각자 topic을 만들어 publish 하고 모든 사용자가 서로의 topic을 죄다 가입한 후 topic을 보면서 구분할 수 있는데 이 경우 subscribe하기가 매우 번거롭다.

Wildcard를 이용하여 이런 요구를 해결할 수 있다.

1. Single Level : +

해당 레벨에 한하여 topic을 확장한다.
chatroom/roomA/+/profile로 subscribe를 하면

아래와 같이 topic들이 있을 경우

chatroom/roomA/userA/message (X)
chatroom/roomA/userA/profile (O)
chatroom/roomA/userA/status (X)
chatroom/roomA/userB/message (X)
chatroom/roomA/userB/profile (O)
chatroom/roomA/userB/status (X)
chatroom/roomB/userC/message (X)
chatroom/roomB/userC/profile (X)
chatroom/roomB/userC/status (X) 
chatroom/roomB/userD/message (X)
chatroom/roomB/userD/profile (X)
chatroom/roomB/userD/status (X)

roomA와 profile이 있는 topic에 모두 subscribe 한다.

2. Multi Level : #

해당 레벨과 그 하위 topic 모두 subscribe 한다.
마찬가지로 chatroom/roomA/# 로 subscribe를 하면

chatroom/roomA/userA/message (O)
chatroom/roomA/userA/profile (O)
chatroom/roomA/userA/status (O)
chatroom/roomA/userB/message (O)
chatroom/roomA/userB/profile (O)
chatroom/roomA/userB/status (O)
chatroom/roomB/userC/message (X)
chatroom/roomB/userC/profile (X)
chatroom/roomB/userC/status (X) 
chatroom/roomB/userD/message (X)
chatroom/roomB/userD/profile (X)
chatroom/roomB/userD/status (X)

roomA 의 모든 topic을 subscribe 한다.

주의사항. 
1. topic을 만들때 /chatroom 과 같이 /로 먼저 시작하지 말것.
2. space를 사용하지 말것
3. ASCII만 사용할 것 ( CR/LF 등등 안보이는 문자를 제외)
4. $로 시작하는 https://github.com/mqtt/mqtt.github.io/wiki/SYS-Topics 과 충돌을 고려할 것

댓글

이 블로그의 인기 게시물

세상 간단한 https(+secured websocket): Caddy

nginx, apache2 같은 걸로 매번 certbot 연동을 통해 https 하는게 지겨워서 알아보니 Caddy라는게 있더라. 설치법은 강하게 크기 위해 알아서 해본다. # cat /etc/caddy/Caddyfile your.shitty.site:8123 {   proxy / localhost:9123 {     websocket     transparent   } } 이건 외부에서 8123으로 들어오는 걸 내부적으로 9123로 맞춰서 https 맞춰주는 reverse proxy. 만일 port를 생략하면 # cat /etc/caddy/Caddyfile your.shitty.site {   proxy / localhost:9123 {     websocket     transparent   } } 기본포트인 443으로 되어 https://your.shitty.site 로 접속이 된다. 요새 말썽이던 cloudflare 버리고 netlify domain이랑 caddy를 쓰니까 앓던 이가 빠진 느낌. 이 조합은 당분간 계속 써야겠다 싶다.

저지연 오디오 생성 LLVC 사용기

https://github.com/KoeAI/LLVC 써봄 CUDA 11.8 버전 쓰고 있어 pip install torch torchvision torchaudio --index-url https://download.pytorch.org/whl/cu118 VC 없어서 설치 https://wikidocs.net/168848 참조 FAIRSEQ 관련 오류 https://github.com/facebookresearch/fairseq/issues/2908 pip install editdistance  설치 No CUDA runtime is found, using CUDA_HOME='C:\Program Files\NVIDIA GPU Computing Toolkit\CUDA\v11.8' 오류 멀쩡하게 있는데 안됨. pip install torch==2.1.0+cu118 torchvision==0.16.0+cu118 torchaudio==2.1.0+cu118 --extra-index-url https://download.pytorch.org/whl/cu118 다시 설치 set DISTUTILS_USE_SDK=1 이게 문젠가 설정하고 재도전 Using cached ruamel.yaml.clib-0.2.8-cp311-cp311-win_amd64.whl (118 kB) Building wheels for collected packages: fairseq   Building wheel for fairseq (pyproject.toml) ... error   error: subprocess-exited-with-error   × Building wheel for fairseq (pyproject.toml) did not run successfully.   │ exit code: 1   ╰─> [1829 lines of output]       No CUDA runtime is found, usi...