pvbrowser MySQL 사용하기 - Modbus 통신 데이터 Database 에 저장하기

자, Database에 연결하였고, DB에 데이터도 넣어보았습니다.

데이터를 자동으로 입력해 보죠.
제가 사용하는 방법이 틀릴수도 있습니다. 작동이 되지않는다 그런 문제가 아니라 시스템에 부하가 많이 가해질수도 있고, 에러가 발생한 우려도 있다는 겁니다. 그러니 이 사람은 이런 식으로 사용하는구나... 라고 생각하시기 바랍니다.

SCADA, HMI, 기타... 등등, 대부분의 데이터 수집 장치는 백그라운드에서 일정 주기 간격으로 데이터를 수집합니다. 사용자가 수집된 데이터를 버튼을 이용해 저장하는 것은 극히 드물죠

가장 중요한 개념은 백그라운드에서 일정주기 간격으로 저장한다.

pv서버 프로그램에서 백그라운드는 무엇일까요, 뭐, 서버프로그램 자체가 백그라운드라고 말한다면, 할 말없고, 여하튼 main, mask,... 제가 볼때 main이 백그라운드 입니다. mask 프로그램은 호출받을때만 실행되므로, mask에 주기적으로 데이터를 저장하는 코드를 집어넣어도 제대로 작동하지 않습니다. 만약 mask가 한개만 있다면 가능하죠. 그러나 여러 mask를 사용하는 경우는 제대로 작동하지 않습니다.

일정주기 간격으로 저장할려면 어떻게 해야 할까요? 이건 이벤트 혹은 인터럽트 개념인데...

여하튼 골치 아픈 문제 입니다.
QTimer와 signal Slot을 이용하여 해결해 보려고 했는데 yahoo Group 에 있는 pvbrowser 항목을 살펴보니 이건...OTL... pvbrowser는 Qt를 이용해 개발했지만 다른 쪽은 아니라는 식으로 설명되어 있네요.

그냥 스레드를 하나 만들어 처리하는 식으로 방향을 잡고 진행해 보도록 하겠습니다.

스레드 만들기

그럼 스레드 만드는 법을 살펴보죠.
스레드를 만들기 위해서 사용하는 라이브러리가 "rlthread.h"입니다. 헤더 파일에 정의해 놓고 넘어가죠.

메인 함수에 다음과 같은 코드를 집어 넣었습니다.

rlThread timerBase; static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; return arg; }

pvInit(ac,av,&p); /* here you may interpret ac,av and set p->user to your data */ //Thread timerBase.create(timerBaseThread, NULL);

간단히 말하면 timerBase라는 rlThread 객체를 만들었습니다. 그리고 객체(timerBase)가 사용할 함수(timerBaseThread())를 하나 만든 후 rlthread에서 지원하는 create()함수를 이용하여 스레드를 만들었습니다.
간단하죠, 우선은 인자로 NULL을 넘겨 주었습니다.

timerBaseThread() 함수를 수정하여 5초마다 '>>I'm alive." 문장을 출력하도록 해보죠.
만들어진 Thread가 주기적으로 작동하는지 확인하기 위해서...

static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; time_t delayTime = time(0) + 5; int counter = 1; while(1) { if(time(0) > delayTime) { printf(">>I'm alive! Counter =%d\n", counter++); delayTime = time(0) + 5; } } return arg; }

timer를 사용하기 위해 C 표준함수인 <ctime.h>을 사용하였습니다. 헤더파일 수정해 주시기 바랍니다.

서버를 시작한 후 확인해 보았습니다.

그림 1. 서버 실행화면

5초마다 자기가 살아있다는 메시지를 출력하는 군요. 시간은 정확한 5초가 아니고 5초 이상에서 한번씩 나타납니다...(이것은 본인 실력이 이것 밖에 되지 않으니 이해해 주시기를...)

Modbus 입력 데이터 Database에 저장하기

그럼 timeBaseThread() 함수에서 지난번에 만든 Arduino Modbus에서 수집한 데이터를 읽어 들여오도록 코드를 수정해보죠. 5초 이상의 간격으로 데이터를 수집하는 구문입니다. 


static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; unsigned short sqlData[29; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; int counter = 1; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2, 0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); } } return arg; }

modbus에서 넘어오는 dataInterval 변수로 지정한 주기로 저장하기 위해 unsigned short 형식의 sqlData 배열을 정의하였습니다. 살펴보시면 특이 사항이 없기 때문에 실행해보죠.

그림 2. 서버실행화면-Modbus Data

Arduino에서 난수 형태의 데이터가 넘어오는 것을 확인할 수 있습니다. 잘 동작하네요.

지금까지의 내용이 "백그라운드에서 일정주기 간격으로 저장한다." 라는 개념을 반영한 것입니다.



자, 그럼 최종적으로 이 데이터를 Database에 저장해보죠.

지금부터의 내용은 본인이 제대로 이해하지 못하면서, 작동하게만 만들어 놓은 코드입니다.
즉, 정확한 내용(혹은 방법)이 아닐 수 있습니다. 하지만 동작하는데 이상은 없었습니다. 마음에 드는 코드는 아니지만...

우선 DataType을 하나 정의 했습니다.

typedef struct { PARAM *p; } myThreadData;

특이한 것 없습니다. 나중을 위해.... 특이한 것은 PARAM *p 를 이용했다는 것.


static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; myThreadData *d = (myThreadData *)p->user; char queryBuffer[2048]; string sqlQueryBuffer; unsigned short sqlData[29; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); p->thread->lock(); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2, 0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); p->thread->unlock(); p->thread->lock(); int ret = db.query(d->p, "INSERT INTO Arduino (data00, data01, data02) VALUES(10, 20, 30)"); printf("db.query = 'insert *' re=%d\n", ret); p->thread->unlock(); } } return arg; }

Header 함수에 string 함수를 사용하기 위해 다음과 같이 하여 주시기 바랍니다.

#include <string> using namespace std;

여기서 이해 되지 않는 부분이

myThreadData *d = (myThreadData *) p->user;

db.query(d->p, "INSERT INTO Arduino .....");

myThreadData 로 d 를 정의하여야 query에서 인식을 하는데 왜 그런지다시 한번 확인해 보자...여하튼 지금은 그냥 넘어가자.

컴파일 후

그림 3 pvbrowser 실행화면

그림3과 같이 데이터가 주기적으로 계속 저장되고 있습니다.
비록 Arduino에서 넘어온 데이터는 아니지만....

자 Arduino에서 넘어온 데이터를 Database에 넣어 보죠.

설명하기 귀찮아서아래와 같은 코드를 작성하였습니다.

// // Thread for timerBase // static void *timerBaseThread(void *arg) { THREAD_PARAM *p= (THREAD_PARAM *) arg; myThreadData *d = (myThreadData *)p->user; char queryBuffer[2048]; string sqlQueryBuffer; string stringTemp; int sqlData[29]; int dataInterval = 5; time_t delayTime = time(0) + dataInterval; while(1) { if(time(0) > delayTime) { printf(">>Thread Work!....\n"); p->thread->lock(); for(int i = 0; i < 29; i++) sqlData[i] = modbus.readShort(i*2,0); printf(">>Modbus Data at 3 : %d\n", sqlData[3]); p->thread->unlock(); sqlQueryBuffer = "INSERT INTO Arduino ("; sqlQueryBuffer += "data00, data01, data02, data03, data04, data05, data06, "; sqlQueryBuffer += "data07, data08, data09, data10, data11, data12, data13, "; sqlQueryBuffer += "data14, data15, data16, data17, data18, data19, data20, "; sqlQueryBuffer += "data21, data22, data23, data24, data25, data26, data27, "; sqlQueryBuffer += "data28) VALUES ("; stringTemp = ""; sprintf(queryBuffer, " %d", sqlData[0]); stringTemp += queryBuffer; for (int i = 1; i < 29; i++) { sprintf(queryBuffer, ", %d", sqlData[i]); stringTemp += queryBuffer; } stringTemp += ");"; sqlQueryBuffer += stringTemp; strcpy(queryBuffer, sqlQueryBuffer.c_str()); // string to char* conversion printf(">>Query : %s\n", queryBuffer); p->thread->lock(); int ret = db.query(d->p, queryBuffer); printf("db.query = 'insert *' re=%d\n", ret); p->thread->unlock(); delayTime = time(0) + dataInterval; } } return arg; }


코드 최적화를 해야하는데 실력이 되지 않네요. 여하튼 실행시키면 그림 4와 같은 화면이 나타납니다.

그림 4. 서버 실행화면

그림 5. pvbrowser 실행화면

pvbrowser 화면에서 확인해 보았습니다. 잘 되는 군요.

뒤로 갈수록 설명이 영 엉망이네요. thread관련 부분은 다시 한번 검토해 보아야 할 것 같습니다.