Mac : mosquitto 브로커로 MQTT 통신 in 터치디자이너

mosquitto_pub -h 127.0.0.1 -p 1883 -t 1 -i timetalkmaster -m "hello"

mac 에 mosquitto를 설치

https://miin29na.tistory.com/74

[MQTT]Mosquitto 설치/테스트 (맥북)

> brew install mosquitto

> brew services start mosquitto

 

#subscribe

js-MacBookPro:~ js.k$ mosquitto_sub -h localhost -p 1883 -t topic 

Hello message


#publish

js-MacBookPro:~ js.k$ mosquitto_pub -h localhost -p 1883 -t topic -m "Hello message"

https://icubex.com/pishield/pishield-touchdesigner-via-mqtt/

PiShield->TouchDesigner via MQTT – Infusion Systems

 

[콘솔에서 퍼블리쉬해보고 MQTT BOX로 확인하기]

mosquitto_pub -h 127.0.0.1 -p 1883 -t 1 -i timetalkmaster -m "hello"

<퍼블리쉬>

-h  : 맥 ifconfig 해서 나온 주소

-p : 포트번호 기본 1883

-t  : 토픽

-i : 

-m : "메세지내용"

 

<mqttbox 에서 확인하기>

---

mac terminal 명령어 정리

ls : list 조회

cd : 이동

cd .. : 상위 디렉토리로 이동

cd ~ :  홈디렉토리로 이동

mkdir 디렉토리명 : 폴더생성

rmdir 디렉토리명 : 폴더삭제

touch  파일명.확장자명 : 파일생성

clear : 화면 클리어하기

cp  대상파일명 변경파일명 타겟경로 :  복사

mv : 이동

rm : 삭제

cat : 텍스트 파일 열기

vi : ** 파일 편집기 실행

grep : 파일안 내용찾기

sudo : 관리자 권한으로 실행

...

모스퀴토 명령어

모스키토 설치 : brew install mosquitto

​

모스키토 서비스 실행 : brew services start mosquitto

​

모스키토 서비스 중지 : brew services stop mosquitto

​

모스퀴토.conf 경로  /usr/local/etc/mosquitto/mosquitto.conf 

-> sudo nano mosquitto.conf

#listener
listener 1883
# listener 8883
# protocol mqtt
listener 8088
protocol websockets

메세지 구독 : mosquitto_sub -h [주소] -p [포트] -t [주제, 방제목]

​

메시지 발행(퍼블리싱) : mosquitto_pub -h [주소] -p [포트] -t [주제, 방제목] -m [메세지]

---

[TouchDesigner 에서 실습]

1. subscribe 해서 메세지 받기

mosquitto_pub -h 127.0.0.1 -p 1883 -t 1 -i timetalkmaster -m "hello"

project1 에서 mqttclient1 로 mqtt 신호 받겠다. 

주소는 로컬 포트는 1883

이것을  mqttclient1_callbacks에 입력

# me - this DAT
# project1 컴포지션에서 mqttclient1 오퍼레이터를 a 로 지정하고
a= op('/project1/mqttclient1')
#구독하겠다 토픽 1 'qos'=0 메세지 한번보낸다는뜻
a.subscribe('1',qos=0)

# Called when connection established
# dat - the OP which is cooking
def onConnect(dat):
	print('connect')
	return

# Called when connection failed
# dat - the OP which is cooking
# msg - reason for failure
def onConnectFailure(dat, msg):
	return

# Called when current connection lost
# dat - the OP which is cooking
# msg - reason for failure
def onConnectionLost(dat, msg):
	return

# Called when server receives subscription request
# dat - the OP which is cooking
def onSubscribe(dat):
	return

# Called when subscription request fails.
# dat - the OP which is cooking
# msg - reason for failure
def onSubscribeFailure(dat, msg):
	return

# Called when server receives unsubscription request
# dat - the OP which is cooking
def onUnsubscribe(dat):
	return

# Called when unsubscription request fails.
# dat - the OP which is cooking
# msg - reason for failure
def onUnsubscribeFailure(dat, msg):
	return

# Called when server receives publish request
# dat - the OP which is cooking
def onPublish(dat):
	return

# Called when new content received from server
# dat - the OP which is cooking
# topic - topic name of the incoming message
# payload - payload of the incoming message
# qos - qos flag for of the incoming message
# retained - retained flag of the incoming message
# dup - dup flag of the incoming message
#여기서 메세지 출력(받은내용 payload)
def onMessage(dat, topic, payload, qos, retained, dup):
	print('recieved message' , payload)
	if(topic == '1'):
		print('OK')
	return

터디 콘솔창

구독취소

https://icubex.com/pishield/pishield-touchdesigner-via-mqtt/

PiShield->TouchDesigner via MQTT – Infusion Systems

2. publish : 메세지 보내기

https://youtu.be/-_6GoJguurs

mqttclient 를 이름을 mqttclient_publish 로지정해주고

callback DAT를 원하는 DAT 으로 지정해준다

publish 코드 작성후

a= op('/project1/mqttclient_publish')
msg = 'b' + '"' + str("hi123") + '"'
a.publish('1',eval(msg),qos=0,retain=True)
print("send OK")

mqtt box 앱으로 받아진 정보 확인한다 

 

>>> 다음 웹(front)에 연결해서 mqtt 값 받아 보기