MQTTClient 통신드라이버는 MQTT 프로토콜을 사용하여 메시지를 주고받기 위한 통신 드라이브이다.
아래의 읽기설정으로 MQTT Subscribe(구독) , 쓰기설정으로 MQTT Publish(발행) 기능을 지원한다.
주의) 1. paho-mqtt3as.dll 파일을 PLC_SCAN.exe 가 위치한 폴더나 PROTOCOL 폴더에 위치시켜야 한다. (EPL-2.0 라이센스) (Autobase 10.3.6.21 부터 기본 배치)
2. ssleay32.dll, libeay32.dll 파일을 PLC_SCAN.exe 가 위치한 폴더에 위치시켜야 한다. (Autobase 10.3.6.21 부터 기본 배치)
3. msvcp90d.dll 파일을 PROTOCOL\Microsoft.VC90.DebugCRT 폴더에 위치시켜야 한다. (Autobase 10.3.6.21 부터 기본 배치)
>> MQTTClient 통신드라이버 관련 설치폴더로 이동
4. Visual Studio 2015용 Visual C++ 재배포 가능 패키지( vc_redist.x86.exe )를 설치해야 한다.
https://www.microsoft.com/ko-kr/download/details.aspx?id=48145
<그림 1>은 MQTTClient 통신 드라이버를 사용하여 통신파일을 편집한 예시이다.
|
|
| <그림 1> MQTTClient 통신 드라이버의 통신파일 편집 예 |
<그림 1>에서 MQTTClient 통신 드라이버의 통신파일을 아래 정보에 맞게 편집한다.
디바이스 : None.
읽기주기 : 읽기주기마다 메시지수신횟수 갱신, 에러발생 및 연결상태 확인이 이루어지므로 최대한 짧게 설정한다. (1초 이하)
메시지수신은 별도의 스레드에서 이루어지므로, 읽기주기와 관계없이 수신 시 즉시 메모리에 저장된다.
쓰기주기 : 쓰기주기마다 메시지발행(Publish) 가 이루어지므로, 최대한 짧게 설정한다.
읽기시간초과 : 연결실패 시 재연결 시도 주기이므로, 2초 ~ 60초 사이로 설정한다.
쓰기시간초과 : 사용안함.
또한 옵션 부에는 연결할 MQTT Broker의 host, port, SSL 사용여부 를 콤마( , )로 구분하여 입력한다.
주의) 기본값은 broker.mqtt-dashboard.com, 1883, 0, 이다.
( 이 주소는 HIVEMQ 사의 공개 MQTT Broker 이므로, 토픽과 메시지 내용이 모두 공개된다.)
( 이 주소는 Test 용도로 사용하고, 현장에서 사용하는 서버나 자체적으로 구축한 MQTT Broker 주소로 변경하도록 한다. )
MQTTClient 드라이버의 읽기 작성 형식
MQTTClient 통신 드라이버의 읽기요청문은 'READ' 만 작성한다.
읽기 설정 예)
READ,
<그림 1> 프로토콜 옵션부의
아이콘을 클릭하면 <그림 2>의 대화상자가 나타나는데 여기서
구독(Subscribe) 할 주제(Topic) 목록을 작성할 수 있다.
구독 목록(Subscribe Items)은 주제(Topic), 서비스품질(QoS), 저장할 통신프로그램 위치(SaveBufferAddress)를 콤마( , ) 로 구분하여 입력한다.
작성한 구독목록은 \SCAN\SUBSCRIBE%03d.txt 형태로 저장되고, 통신 시작 시 한꺼번에 구독이 시작된다.
구독목록의 주제가 중복될 경우, 읽은 메시지는 먼저 작성한 순서의 메모리주소에 저장된다.
와일드카드( + , # ) 문자는 지원하지 않는다.
또한, 접속할 MQTT Broker Host, Port, SSL 사용여부, SSL 인증서 경로(CA File, Cert File, pritvateKey), Username, Password 를 작성할 수 있다.
Host : 연결할 MQTT Broker의 host
Port : 연결할 MQTT Broker의 port
Use SSL : TLS/SSL 연결 사용여부
CA File : 서버용 인증서 경로 (사용하지 않는 경우, 비워둠.)
Cert File : 클라이언트용 인증서 경로 (사용하지 않는 경우, 비워둠.)
privateKey : 클라이언트용 개인 키 경로 (사용하지 않는 경우, 비워둠.)
Username : 클라이언트 ID (사용하지 않는 경우, 비워둠.)
Password : 클라이언트 Password (사용하지 않는 경우, 비워둠.)
 |
| <그림 2> MQTTClient 통신 드라이버의 옵션 대화상자의 |
MQTTClient 통신 드라이버의 읽은 값은 WORD/DWORD/FLOAT/DOUBLE/STRING 메모리에 동일한 값(저장형식만 다름)이 저장된다.
단, 수신된 메시지가 255자를 초과할 경우, "[프로젝트경로]\SCAN\MQTT\[토픽명].txt 파일에 메시지가 저장된다. (토픽명의 슬래시 ( / ) 문자는 밑줄 ( _ ) 로 치환된다.)
그리고 저장할 메모리(STRING) 위치에 해당 경로명이 저장된다.
MQTTClient 드라이버의 쓰기 설정으로 MQTT 발행(Publish) 기능을 사용할 수 있다.
2-1 . 디지털 쓰기
디지털 쓰기 기능은 지원하지 않는다.
2-2. 아날로그 쓰기
아날로그 쓰기를 위한 아날로그 출력 태그 설정 내용은 다음과 같다.
1) Port 연결된 통신포트 번호. (COM 번호가 아님)
2) Station retain 기능 사용 유무. ( 0 또는 1)
3) Address 사용안함.
4) Extra1 발행(Publish)할 주제명(Topic name)
5) Extra2 QoS(Quality of Service) (0 , 1 , 2 중 선택.)
예제
1)
PORT : 0 STATION : 1 ADDRESS : 0 EXTRA1 : Autobase/gr1/AI_0000 EXTRA2 : 10 으로 설정하고 아날로그 출력을 하면 토픽 : Autobase/gr1/AI_0000, 값 : 10 을 발행한다. (Retain ON)
예제 2)
@PlcScanWriteWord(0, 1, 0, "my/test/topic1", 0, 1.1); // 토픽 : my/test/topic1, 값 : 1.1 을 발행한다. (Retain ON)
예제 3)
@PlcScanWriteWord(0, 0, 0, "Autobase/gr1/DI_0000", 0, $DI_0000); // 토픽 : Autobase/gr1/DI_0000, 값 : [$DI_0000 값] 을 발행한다. (Retain OFF)
2-3. 블록 쓰기 (문자열 메시지 발행)
블록쓰기는 스크립트의 @PlcScanWriteBlock 함수를 사용하여 다음과 같이 설정한다.
스크립트 이름과 형식 : @PlcScanWriteBlock(int port, int station, int address, string extra1, int extra2, object array_value, int array_size);
MQTTClient 프로토콜에서는 다음 형식으로 동작한다.
@PlcScanWriteBlock(int port, int retain, 0, string topic, int QoS, object array_value, int array_size);
예제 1)
@strcpy(buf, "Test Value");
size = @strlen(buf);
@PlcScanWriteBlock(0, 1, 0, "my/test/topic1", 0, buf,
size); // 토픽 : my/test/topic1 , 메시지 : Test Value 를 발행한다. (Retain ON)
예제 2)
@strcpy(buf, $ST_0000);
size
= @strlen(buf);
@PlcScanWriteBlock(0, 0, 0, "Autobase/Alarm/msg1", 0, buf,
size); // 토픽 : Autobase/Alarm/msg1 , 메시지 : [문자열태그 $ST_0000의 값] 을
발행한다. (Retain ON)