vsc interface 는 OVC 와 OVS 간 인터페이스이며,
해당 인터페이스은 MQTT 프로토콜로 개발되며,
본 섹션에서는 vsc interface 상에서 OVS 기능을 활용한 프로토콜을 명세하며 상세 프로토콜은
Client Types 에 명세된 단말의 타입에 따라 상이하게 기술됩니다.
Note
본 절을 이해하기 위해서 아래 명시된 프로토콜 및 프로그래밍 언어에 대한 이해가 필요합니다.
- MQTT Protocol
- Node.js Program Language
OVC-g 단말을 위한 vsc Interface의 Flow는 다음과 같으며, 각 단계별로 절차를 Node.js 기반 코드로 소개합니다.
도식화된 Flow는 크게 4가지 단계 Stage 로 구성됩니다. 일반적으로 V2X Event Report 와
V2X Event Notification Reception 은 순서와 상관없이 이벤트 발생에 따라 비동적으로 발생합니다.
| Stages | Description |
|---|---|
| Preparation | OVC-g가 OVS 상호 간 서비스를 호출하기 위해서 필요한 연결, 인증, 푸시 메시지 수신을
위한 설정 등 기본적인 항목을 준비하는 단계
|
| Location Report | OVC-g가 GPS로부터 수신한 현재 위치를 OVS에 주기적으로 반복 보고하는 단계
|
| V2X Event Report | OVC-g가 VAC로부터 전달받은 V2X Event를 OVS에 보고하는 단계
|
| V2X Event Notification Reception | OVS가 타 OVC로부터 전달받은 V2X Event 중 해당 OVC-g와 연계된 Event를
푸시하여 OVC-g가 수신하는 단계
|
아래부터는 상기 vsc-g Flow의 순서를 간단한 예제 코드와 함께 설명합니다.
1.
Connect to OVS 순서에서는 OVC-g가 OVS에 연결하는 단계입니다. MQTT Broker에 접속하는 connect 단계
MQTT Connect 참고 와 동일합니다.
단, 접속할 때는 다음 Parameter를 적용하여 connect 합니다.
| Parameters | Value |
|---|---|
| host | tcp://192.168.1.170 |
| port | 1883 |
| username | 발급된 고객사의 userName |
| password | 발급된 고객사의 passWord |
| clientId | 단말 식별 번호 (기능상 UserName과 동일하게 처리 가능) |
| cleanSession | true |
| keepAlive | 60 |
Example Code
var mqtt = require('mqtt');
//OVS 접속 및 설정
var messageSender = mqtt.connect({
host: 192.168.1.170,
port: 1883,
username: {고객사에서 등록한 username},
password: {고객사에서 등록한 password},
clean: true,
keepalive: 60,
protocol: 'mqtt'
});
//OVS 접속 시도에 따른 Callback
messageSender.on('connect', function(connack) {
if (connack.cmd == 'connack'){
// 성공적인 OVS 접속
} else
// 접속 실패, 및 원인 파악 필요
});2.
Subscribe a topic for receiving V2X notification 순서에서는
OVC-g가 향후에 V2X Event 수신 할 수 있도록 V2X Event을 제공하는 Topic에 Subscription을 합니다.
Topic은 아래와 같은 룰을 따라 설정합니다.
| Topic | v2x/device/{userName} |
Example Code
messageSender.subscribe('v2x/device/{userName}, {qos: 1}, function(err, granted) {
if (err)
{
// Topic에 정상적으로 Subscribe 되지 않는 경우 원인
} else {
// Topic에 정상적으로 Subscribe 된 경우
}
});3.
Publish OVC-g's Current Location 순서에서 선행되어야 하는 조건은 OVC-g 단말이 GPS 센서로 현재 자신의 위치 좌표를 받는 것입니다.
GPS 좌표를 정상적으로 수신 한 경우에 OVC-g는 자신의 위치를 OVS에 전달 Publish 합니다. 전달 시에는 다음의 Topic에 Publish를 합니다.
추가로 본 과정은 OVS-g가 GPS 좌표를 획득할때 마다 반복되며, 일반적으로 V2X 서비스 품질을 고려하여서는 1초마다 진행해야 하나 고객사의 입장에 따라 주기가 증가할 수 있으나 주기가 증가할 수록 일부 V2X 서비스 및 서비스 품질이 떨어집니다.
| Topic | v2x/location |
본 순서에서 메시지를 전달할때는 다음 메시지를 JSON 형태로 포함합니다.
| Key | M/O | Type | Description |
|---|---|---|---|
| dev_type | M | Integer | OVC-g를 탑재한 단말의 타입 |
| time | M | Integer | 메시지 전달 시간 (msec, epoch) |
| dev_id | M | String | OVS에 등록된 단말 식별자 |
| speed | O | Integer | 현재 속도 값 |
| location | M | 현재 위치 좌표 (WGS84 Coordination)
Child key로 "lat", "lon" 를 적시
|
Example Data
{
"dev_type": 97,
"time": 1571273913571,
"dev_id": 3333,
"speed": 60,
"location": {
"lat": 37.510296,
"lon": 127.062512
}
}Example Code
var locationReportData = {
"dev_type": {dev_type},
"time": new Date().getTime(),
"dev_id": {deviceID},
"speed": {speed},
"location": {
"lat": {lat},
"lon": {lon}
}
};
sendingMSG = JSON.stringify(eval(locationReportData));
messageSender.publish('v2x/location', sendingMSG, {qos: 1}, function());4. Publish V2X Event detected by OVC-g 순서에서는 OVC-g가 VAC로부터
해당 단말이 인식한 V2X Event를 수신 받은 경우, 이를 OVS에 리포팅하여 OVS가 다른 OVC 에게 전달하는 과정을 유도하는 과정을 기술합니다.
Topic은 아래와 같은 룰을 따라 설정합니다.
| Topic | v2x/event |
본 순서에서 메시지를 전달할때는 다음 메시지를 JSON 형태로 포함합니다.
| Key | M/O | Type | Description |
|---|---|---|---|
| time | M | Integer | 메시지 전달 시간 (msec, epoch) |
| eventType | M | Integer | 이벤트 종류 (To-be-specified) |
| distanceToEvent | O | Integer | 이벤트 지점까지의 거리 |
| location | M | 이벤트 발생 위치 정보 (WGS84 Coordination)
Child key로 "lat", "lon" 를 적시
|
Example Data
{
"time": 1571308818766,
"eventType": 1,
"distanceToEvent": -10,
"location": {
"lat": 37.51477,
"lon": 127.060067
}
}Example Code
var v2xEventReportData = {
"time": new Date().getTime(),
"eventType": 1,
"distanceToEvent": -10,
"location": {
"lat": latitudeValue[sequence % latitudeValue.length],
"lon": longitudeValue[sequence % latitudeValue.length]
}
};
sendingMSG = JSON.stringify(eval(v2xEventReportData));
messageSender.publish(utils.eventTopic, sendingMSG, {qos: config.qos}, function(){
console.log(colors.cyan('Message [JSON | ' + Buffer.from(JSON.stringify(eval(v2xEventReportData))).length + ' Bytes] : '
+ JSON.stringify(eval(v2xEventReportData), 0, 2) + '\n'));
});5. Receive a V2X Event Notification relevant to OVC-g 순서는 OVS에서 타 OVC로부터 수신 받은 V2X 이벤트 중에서
해당 OVC-g와 연계된 이벤트인 경우에 해당 이벤트 메시지를 푸시 형태로 수신하는 순서입니다.
기존 2번 순서에서 Subscribe한 Topic으로 해당 메시지를 수신하게 되며, 해당 단계를 구현하기 위한 샘플 코드는 아래와 같습니다.
Example Code
messageSender.on('message', function(topic, message) {
var msgs = message.toString();
var topic = topic.toString();
var requestId = topic.toString().split('/')[5];
// 수신한 V2X 메시지 로그 출력
if (msgs != null){
console.log(colors.magenta(' == Receive the OVS event Message from OVS == ') + '\n');
console.log(colors.magenta('Topic :' + topic + '\n'
+ 'Message : ' + JSON.stringify(JSON.parse(msgs), 0, 2) + '\n'));
// 수신한 메시지 처리 결과를 OVS에 보고하는 함수 호출
// 상기 함수는 다음 단계와 연계됨
responseOVSEventMsg(requestId);
}
});6. Publish the result of the notifcation message handling 순서는 OVC에서 5번째 순서에서 수신한 이벤트를
처리한 결과를 OVS로 송신하는 순서입니다. 본 순서는 향후 OVSE를 활용하는 고객사들께서 V2X 서비스 통계 자료 제공에 중요한 과정입니다.
OVS에서 발송한 메시지의 처리 결과를 일정 시간(To-be-specified) 내 수신하지 못하면 정상 처리가 안된 것으로 간주합니다.
처리 결과 코드 (To-be-specified)
Example Code
function responseOVSEventMsg(arg){
var sendingMessageObj = {
"results" : 2000
};
var sendingMessageJSON = JSON.stringify(sendingMessageObj, 0, 2);
messageSender.publish(utils.eventAckTopic, sendingMessageJSON, {qos: config.qos}, function() {
console.log(colors.magenta(' == Successfully sending a ACK message to OVS == ') + '\n');
console.log(colors.cyan('Message : ' + sendingMessageJSON) + '\n');
});
}