Nothing Special   »   [go: up one dir, main page]

KR100447394B1 - 통신시스템의 메시지처리방법 - Google Patents

통신시스템의 메시지처리방법 Download PDF

Info

Publication number
KR100447394B1
KR100447394B1 KR10-2001-0068087A KR20010068087A KR100447394B1 KR 100447394 B1 KR100447394 B1 KR 100447394B1 KR 20010068087 A KR20010068087 A KR 20010068087A KR 100447394 B1 KR100447394 B1 KR 100447394B1
Authority
KR
South Korea
Prior art keywords
message
priority
processing
processed
messages
Prior art date
Application number
KR10-2001-0068087A
Other languages
English (en)
Other versions
KR20030035681A (ko
Inventor
김병진
Original Assignee
엘지전자 주식회사
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by 엘지전자 주식회사 filed Critical 엘지전자 주식회사
Priority to KR10-2001-0068087A priority Critical patent/KR100447394B1/ko
Publication of KR20030035681A publication Critical patent/KR20030035681A/ko
Application granted granted Critical
Publication of KR100447394B1 publication Critical patent/KR100447394B1/ko

Links

Classifications

    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04WWIRELESS COMMUNICATION NETWORKS
    • H04W4/00Services specially adapted for wireless communication networks; Facilities therefor
    • H04W4/12Messaging; Mailboxes; Announcements
    • H04W4/14Short messaging services, e.g. short message services [SMS] or unstructured supplementary service data [USSD]
    • HELECTRICITY
    • H04ELECTRIC COMMUNICATION TECHNIQUE
    • H04LTRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L51/00User-to-user messaging in packet-switching networks, transmitted according to store-and-forward or real-time protocols, e.g. e-mail
    • H04L51/04Real-time or near real-time messaging, e.g. instant messaging [IM]

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Computer And Data Communications (AREA)
  • Communication Control (AREA)

Abstract

본 발명은 통신시스템의 임의의 모듈로부터 Time값이 포함된 이벤트 메시지를 수신하여 저장시키는 메시지수신단계와, 상기 메시지수신단계후에 설정된 우선 순위조건에 따라 큐에 저장된 메시지의 우선순위값(Priority)을 결정하여 소트시키는 메시지 우선순위 설정단계와, 상기 메시지 우선순위 설정단계후에 설정된 우선순위에 따라 타임값을 참조하여 최우선순위를 갖는 메시지부터 순차적으로 처리하는 메시지처리단계와, 상기 메시지처리단계후에 현재 처리된 메시지중에서 그 설정된 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재하는 지를 확인하는 메시지 오류확인단계와, 상기 메시지 오류확인단계에 의해 현재 처리된 메시지중에서 그 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재함이 확인될 경우 그 정상적으로 처리되지 못한 해당 메시지를 큐에 다시 넣어 재처리하는 메시지 재처리단계로 이루어진 통신시스템의 메시지처리방법을 제공한다.
상기와 같은 본 발명은 모듈간의 프로토콜 메시지 전송시 메시지 전송시간에 따른 타임값이 설정된 메시지를 전송하고 이 전송된 메시지들을 설정된 우선순위에 따라 순차적으로 처리하므로써, 메시지가 적체되는 일없이 원할하게 처리되므로 그에 따라 프로토콜 메시지전송의 효율성을 상당히 향상시킨다.

Description

통신시스템의 메시지처리방법{method for processing a message of the communication system}
본 발명은 통신시스템의 메시지처리방법에 관한 것으로, 특히 모듈간의 프로토콜 메시지 전송시 메시지 전송시간에 따른 타임값이 설정된 메시지를 전송하고 이 전송된 메시지들을 설정된 우선순위에 따라 순차적으로 처리하는 통신시스템의 메시지처리방법에 관한 것이다.
일반적으로 산업사회가 발전함에 따라 일정지점에서 원하는 다른 지점으로데이터를 보다 적절히 그리고 신속히 전송시키기 위한 통신시스템들이 널리 사용되고 있는데, 이러한 통신시스템들은 통상 지리적으로 분산되어 있는 동종간 또는 이기종간 통신기기 혹은 정보기기 또는 프로세서와 또다른 프로세서간을 연결하여 상호간에 자원의 공유와 통신을 가능하도록 네트워크로 연결되는 것이 대부분이다.
예를들어, 교환기와 교환기간이나 혹은 은행과 같은 금융기관의 단말기와 서버간의 연결 또는 프로세서와 프로세서간의 프로토콜을 이용한 연결등 다수 활용되고 있다. 그런데, 상기와 같은 통신시스템에는 대개 통신을 위해 프로토콜을 사용하게 되는대, 이러한 프로토콜을 이용하여 메시지를 다른 프로세서나 모듈로 전송하여 타스크를 처리하게된다.
그러면, 상기와 같은 종래 프로토콜 메시지처리장치를 도 1을 참고로 살펴보면, 통신시스템내에 설치되어 일정모듈(70)로부터 생성된 각종 이벤트 예컨대, 다른 모듈(71)의 장애를 검출하는 메시지를 수신하여 그 발생순서대로 순차적으로 저장출력하는 프리큐(72)와, 상기 프리큐(72)로부터 로드된 처리메시지를 저장처리하는 타스크큐(73)와, 상기 프리큐(72)와 타스큐(73)의 내용을 모니터링하고 그 처리기능을 제어하는 메인모듈(74)로 이루어진다.
여기서, 상기 처리메시지의 구성항목은 통상 사용자의 처리정보가 들어있는 key와, 이전에 처리했던 모듈의 번지가 기록된 prev와, 다음에 처리할 모듈의 번지가 기록된 next로 이루어진다.
한편, 상기와 같은 종래 프로토콜 메시지처리장치의 처리방법을 살펴보면, 먼저 임의 모듈(70)에서 자신이 원하는 이벤트 메시지를 생성하여 메인 모듈(74)이double linked list 큐로 관리하는 프리큐(72)로 전송할 경우 이 프리큐(72)는 메인 모듈(74)의 제어에 따라 각각의 모듈(70)로부터 발생된 메시지를 발생순서에 따라 차례차례 저장한다. 이때, 상기 프리큐(72)는 메인 모듈(74)의 처리제어에 따라 그 발생순서가 가장 오래된 메시지를 타스크큐(73)로 로드시킨다. 그리고, 상기 타스크큐(73)는 메시지 전달 잡(job) 스케쥴링하는 하는 메인모듈(74)로 전달해야 할 메지시들을 프리큐(72)로부터 할당받아 적재한다. 그러면, 상기 메인모듈(74)은 타스크큐(73)를 모니터링하다가 메시지가 로드되면 이 로드된 메시지를 분석하여 해당 목적지의 모듈(71)로 전송한다. 여기서, 상기 프리큐(72)는 메인모듈(74)의 제어에 따라 상기와 같은 과정을 거쳐 하나씩 그 발생순서에 따라 메시지를 처리한다. 이때, 상기 프리큐(72)와 타스크큐(73)는 처리 메시지의 처음을 알리는 Head와 끝을 알리는 Tail로 구성된다. 그리고, 상기 프리큐(72)에서 꺼내어진 메시지는 필요한 처리과정이 종료될 경우 해당 메시지를 프리큐(72)의 끝으로 복귀시켜 프리큐(72)가 empty가 되지않도록 한다.
그러나, 상기와 같은 종래 프로토콜 메시지처리장치의 처리방법은 각 계층간 발생한 메시지 전달시 이벤트가 발생한 순서대로 메시지를 처리하기 때문에 아무리 긴급한 메시지라도 순위가 뒤질 경우 앞의 메시지가 모두 처리된 후에야 비로소 처리되므로 그에 따라 메시지 처리의 효율성이 상당히 저하되었으며, 또한, 메시지의 전송시간이 길더라도 설정된 처리시간이 경과하면 이 메시지의 처리를 중단하고 다음 순위의 메시지를 처리하게 되므로 그에 따라 메시지의 전송에러가 발생되는 문제점이 발생되었다.
이에 본 발명은 상기와 같은 종래 제반 문제점을 해결하기 위해 발명된 것으로, 모듈간의 프로토콜 메시지 전송시 메시지 전송시간에 따른 타임값이 설정된 메시지를 전송하고 이 전송된 메시지들을 설정된 우선순위에 따라 순차적으로 처리하므로써, 메시지가 적체되는 일없이 원할하게 처리되므로 그에 따라 프로토콜 메시지전송의 효율성을 상당히 향상시키는 통신시스템의 메시지처리방법을 제공함에 그 목적이 있다.
본 발명의 다른 목적은 메시지 전송시간에 따른 타임값을 이용하여 메시지 처리시간을 제어하므로 그에 따라 메시지 처리의 오류도 상당히 저감시키는 통신시스템의 메시지처리방법을 제공하는데 있다.
상기와 같은 목적을 달성하기 위한 본 발명은 통신시스템의 임의의 모듈로부터 Time값이 포함된 이벤트 메시지를 수신하여 저장시키는 메시지수신단계와, 상기 메시지수신단계후에 설정된 우선순위조건에 따라 큐에 저장된 메시지의 우선순위값(Priority)을 결정하여 소트시키는 메시지 우선순위 설정단계와, 상기 메시지 우선순위 설정단계후에 설정된 우선순위에 따라 타임값을 참조하여 최우선순위를 갖는 메시지부터 순차적으로 처리하는 메시지처리단계와, 상기 메시지처리단계후에 현재 처리된 메시지중에서 그 설정된 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재하는 지를 확인하는 메시지 오류확인단계와, 상기 메시지 오류확인단계에 의해 현재 처리된 메시지중에서 그 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재함이 확인될 경우 그 정상적으로 처리되지 못한 해당 메시지를 큐에 다시 넣어 재처리하는 메시지 재처리단계로 이루어진 통신시스템의 메시지처리방법을 제공한다.
도 1은 종래 프로토콜 메시지 처리방법을 설명하는 설명도.
도 2는 본 발명의 방법이 적용되는 장치를 설명하는 설명도.
도 3은 본 발명의플로우차트.
<부호의 상세한 설명>
1 : 모듈 2 : 제어대상 모듈
3 : 프리큐 4 : 타스크큐
5 : 메인모듈
이하, 본 발명을 첨부된 예시도면에 의거 상세히 설명한다.
본 발명의 방법이 적용되는 메시지처리장치는 도 2에 도시된 바와같이 메시지의 구성항목에 메시지전송시간에 따른 타임(time)값을 포함하여 생성하는 개별모듈(1)과, 상기 개별모듈(1)로부터 생성된 각종 이벤트 예컨대, 제어대상 모듈(2)의 장애를 검출하는 메시지를 수신하여 저장하는 프리큐(3)와, 상기 프리큐(3)로부터 할당된 처리메시지를 메시지 전달 잡 스케쥴링에 따라 적재하는 타스크큐(4)와, 상기 프리큐(3)와 타스크큐(4)의 내용을 모니터링하고 그 저장된 메시지를 우선순위에 따라 소트(sort)저장하여 처리하는 메인모듈(5)을 포함한다.
여기서, 상기 메시지의 구성항목에는 메인모듈이 설정된 우선순위조건에 따라 그 메시지처리순서를 기입하는 priority와, 이벤트를 발생하는 측에서 작성하는 메시지 전송시간에 따른 타임값을 설정하는 time와, 사용자의 처리정보가 들어있는 key와, 이전에 처리했던 모듈의 번지가 기록된 prev와, 다음에 처리할 모듈의 번지가 기록된 next로 이루어진다.
다음에는 상기와 같은 장치에 적용되는 메시지처리방법을 설명한다.
본 발명의 방법은 도 3에 도시된 바와같이, 초기상태(S1)에서 메시지수신단계(S2)로 진행하여 임의의 모듈로부터 Time값이 포함된 이벤트 메시지를 수신하여 저장시킨다. 그리고, 상기 메시지수신단계(S2)후에 메시지 우선순위 설정단계(S3)로 진행하여 해당 메시지가 어느 지점으로부터 입력되었는지에 따라 기 설정된 우선순위조건을 참조하여 큐에 저장된 메시지의 priority값을 결정하여 소트시킨다. 또한, 상기 메시지 우선순위 설정단계(S3)후에 메시지처리단계(S4)로 진행하여 설정된 우선순위에 따라 타임값을 참조하여 최우선순위를 갖는 메시지부터 순차적으로 처리한다. 그리고, 상기 메시지처리단계(S4)후에 메시지오류판단단계(S5)로 진행하여 현재 처리된 메시지중에서 전송시간의 타임아웃에 따라 정상적으로 처리되지 못한 메시지가 존재하는 지를 판단한다. 이때, 상기 메시지오류판단단계(S5)중에 판단한 결과 만약 현재 처리된 메시지중에서 전송시간의 타임아웃에 따라 정상적으로 처리되지 못한 메시지가 존재하지 않을 경우는 종료단계로 진행한다.
그러나, 상기 메시지오류판단단계(S5)중에 판단한 결과 만약 현재 처리된 메시지중에서 전송시간의 타임아웃에 따라 정상적으로 처리되지 못한 메시지가 존재할 경우에는 메시지 재처리단계(S6)로 진행하여 정상적으로 처리되지 못한 해당 메시지를 큐에 넣어 다시 처리한다.
환언하면, 통신시스템의 임의의 각 모듈(1)에서 자신이 원하는 이벤트 메시지를 생성할 필요가 있을 경우 이 발생되는 메시지의 구성항목에 전송시간에 따른 Time값을 기록한 다음 해당 메시지를 프리큐(3)에 저장한다. 그러면, 상기 프리큐(3)와 타스크큐(4)를 double linked list 큐로 관리하는 메인 모듈(5)은 이들을 모니터링하고 있다가 각각의 모듈(1)로부터 메시지들이 입력될 경우 이들 메시지의 구성항목에 설정된 우선순위조건에 따라 Priority값을 설정하여 소트(sort)시킨다.
즉, 상기 메인모듈(5)은 메시지 구성항목의 priority값을 설정된 우선순위조건 예컨대, 외부 디바이스로부터 전송된 메시지는 제1순위를, 유저에 의해서 설정된 메시지는 제2 순위를, 상위계층으로 전송되는 메시지는 제3 순위를 부여하여 Priority값을 결정한다. 물론, 상기 우선순위조건들을 사용자의 필요에 의해 변경가능하다.
한편, 상기 메인모듈(5)은 프리큐(3)에 들어있는 메시지중에서 priority값이 최우선순위에 있는 메시지순서대로 꺼내어 타스크큐(4)에 넣는다. 즉, 상기 타스크큐(4)는 메시지 전달 잡(job) 스케쥴링하는 하는 메인모듈(5)로 전달해야 할 메지시들을 프리큐(3)로부터 할당받아 적재한다. 그러면, 상기 메인모듈(5)은 최우선순위로 로드된 메시지를 분석하여 해당 목적지의 모듈(2)로 전송하여 메시지를 처리한다.
상기와 같은 과정을 통해 메인모듈(5)은 메시지를 처리하는데, 이때 상기 메시지를 전달받은 모듈은 메시지 항목에 들어있는 데이터들을 참조하여 그에 해당하는 처리를 행한 후 다른 모듈로 전달할 사항이 있으면 메시지 항목에 다시 해당 데이터를 붙여서 타스크큐(4)에 넣는다. 그리고, 상기와 같이 프리큐(3)에서 꺼내어진 메시지는 필요한 처리과정이 종료되면 다시 프리큐(3)의 끝으로 복귀되어 프리큐(3)가 empty상태가 되지 않도록한다.
여기서, 상기 메시지 항목의 time값은 일정시간 간격마다 발생되는 인터럽터에 의해 수행되는 타이머루틴을 이용한 것으로 일정시간마다 감소되는 값이다.
따라서, 상기 메인모듈(5)은 우선순위에 따라 메시지를 처리하면서 상기 time값도 체킹하게되는데, 이때 상기 메시지가 해당 모듈로 모두 전송되기도 전에 상기 time값이 0로 되어 메시지가 time out되는 비정상적인 처리결과가 발생될 경우 이 메시지를 프리큐(3)에 넣어 다시 전송되도록 한다.
이상 설명에서와 같이 본 발명은 모듈간의 프로토콜 메시지 전송시 메시지 전송시간에 따른 타임값이 설정된 메시지를 전송하고 이 전송된 메시지들을 설정된 우선순위에 따라 순차적으로 처리하므로써, 메시지가 적체되는 일없이 원할하게 처리되므로 그에 따라 프로토콜 메시지전송의 효율성을 상당히 향상시키는 장점을 가지고 있다.
또한, 본 발명에 의하면, 메시지 전송시간에 따른 타임값을 이용하여 메시지 처리시간을 제어하므로 그에 따라 메시지 처리의 오류도 상당히 저감시키는 효과도 있다.

Claims (3)

  1. 통신시스템의 임의의 모듈로부터 Time값이 포함된 이벤트 메시지를 수신하여 저장시키는 메시지수신단계와, 상기 메시지수신단계후에 설정된 우선순위조건에 따라 큐에 저장된 메시지의 우선순위값(Priority)을 결정하여 소트시키는 메시지 우선순위 설정단계와, 상기 메시지 우선순위 설정단계후에 설정된 우선순위에 따라 타임값을 참조하여 최우선순위를 갖는 메시지부터 순차적으로 처리하는 메시지처리단계와, 상기 메시지처리단계후에 현재 처리된 메시지중에서 그 설정된 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재하는 지를 확인하는 메시지 오류확인단계와, 상기 메시지 오류확인단계에 의해 현재 처리된 메시지중에서 그 전송시간이 타임아웃됨에 따라 정상적으로 처리되지 못한 메시지가 존재함이 확인될 경우 그 정상적으로 처리되지 못한 해당 메시지를 큐에 다시 넣어 재처리하는 메시지 재처리단계로 이루어진 것을 특징으로 하는 통신시스템의 메시지처리방법.
  2. 삭제
  3. 삭제
KR10-2001-0068087A 2001-11-02 2001-11-02 통신시스템의 메시지처리방법 KR100447394B1 (ko)

Priority Applications (1)

Application Number Priority Date Filing Date Title
KR10-2001-0068087A KR100447394B1 (ko) 2001-11-02 2001-11-02 통신시스템의 메시지처리방법

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
KR10-2001-0068087A KR100447394B1 (ko) 2001-11-02 2001-11-02 통신시스템의 메시지처리방법

Publications (2)

Publication Number Publication Date
KR20030035681A KR20030035681A (ko) 2003-05-09
KR100447394B1 true KR100447394B1 (ko) 2004-09-04

Family

ID=29567679

Family Applications (1)

Application Number Title Priority Date Filing Date
KR10-2001-0068087A KR100447394B1 (ko) 2001-11-02 2001-11-02 통신시스템의 메시지처리방법

Country Status (1)

Country Link
KR (1) KR100447394B1 (ko)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
KR100724859B1 (ko) * 2005-05-18 2007-06-04 삼성전자주식회사 디지털 멀티미디어 방송 수신 장치의 팝업 이벤트 처리방법
CN113138883B (zh) * 2021-05-14 2024-02-02 北京字节跳动网络技术有限公司 消息处理方法、装置、存储介质及电子设备

Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH0630472A (ja) * 1992-07-10 1994-02-04 Mazda Motor Corp 多重伝送装置
KR960015862A (ko) * 1994-10-27 1996-05-22 토마스 더블유. 벅맨 부품용 트레이 및 트레이내에 부품을 정확하게 배치하기 위한 장치
KR100221202B1 (ko) * 1997-05-26 1999-09-15 전주범 통신 시스템의 다중 채널 전송 지연 보상 장치 및 방법
EP0991231A1 (en) * 1998-09-10 2000-04-05 International Business Machines Corporation Packet switch adapter for variable length packets
KR20000074195A (ko) * 1999-05-19 2000-12-15 강병호 다중 경로 비동기 전송 모드 스위치를 위한 고속 셀 순서 처리장치 및 방법

Patent Citations (5)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JPH0630472A (ja) * 1992-07-10 1994-02-04 Mazda Motor Corp 多重伝送装置
KR960015862A (ko) * 1994-10-27 1996-05-22 토마스 더블유. 벅맨 부품용 트레이 및 트레이내에 부품을 정확하게 배치하기 위한 장치
KR100221202B1 (ko) * 1997-05-26 1999-09-15 전주범 통신 시스템의 다중 채널 전송 지연 보상 장치 및 방법
EP0991231A1 (en) * 1998-09-10 2000-04-05 International Business Machines Corporation Packet switch adapter for variable length packets
KR20000074195A (ko) * 1999-05-19 2000-12-15 강병호 다중 경로 비동기 전송 모드 스위치를 위한 고속 셀 순서 처리장치 및 방법

Also Published As

Publication number Publication date
KR20030035681A (ko) 2003-05-09

Similar Documents

Publication Publication Date Title
CN111371892A (zh) 高并发分布式消息推送系统及方法
US5293377A (en) Network control information without reserved bandwidth
JPH0563706A (ja) デジタルデータ処理システムのためのローカルエリアネツトワーク
JPH0411057B2 (ko)
CN101179553A (zh) 用于并行消息的有效保序传递的方法和装置
CN104579905A (zh) 消息传递方法和系统及mom服务器、接收端
CN109120713A (zh) 消息发送失败的处理方法及系统、装置和存储介质
WO2019096046A1 (zh) 数据处理系统、方法及令牌管理方法
EP0366344B1 (en) Multiprocessor load sharing arrangement
CN116467091A (zh) 基于消息中间件的消息处理方法、装置、设备及介质
KR100447394B1 (ko) 통신시스템의 메시지처리방법
JPH0630078B2 (ja) 端末装置初期ロ−ド制御方式
CN111049730A (zh) RabbitMQ消息重传及消费方幂等性解决方法
RU2566953C2 (ru) Способ и устройство для доставки информации
CN102164384A (zh) 提高服务成功率的方法、装置及系统
WO2020067872A1 (en) A method of prioritizing message handling in a publisher/subscriber broker
CN112633855B (zh) 一种任务提醒方法及计算机设备
CN117032987A (zh) 分布式任务调度方法、系统、设备及计算机可读介质
HU224795B1 (en) Method and system for transmitting a chain of messages for database
CN115550284A (zh) 消息处理方法、装置和设备
KR100311619B1 (ko) 분산처리 시스템에서 프로세서간 메시지 송수신 방법
US20200401446A1 (en) Intermediary system for data streams
KR19990053527A (ko) 다중레벨 우선순위 큐를 이용한 클라이언트 서버간 통신 방법
CN110247808A (zh) 信息发送方法、装置、设备及可读存储介质
WO2024052981A1 (ja) 処理装置、処理方法およびプログラム

Legal Events

Date Code Title Description
A201 Request for examination
N231 Notification of change of applicant
E902 Notification of reason for refusal
AMND Amendment
E601 Decision to refuse application
J201 Request for trial against refusal decision
AMND Amendment
B701 Decision to grant
GRNT Written decision to grant
FPAY Annual fee payment

Payment date: 20120727

Year of fee payment: 9

FPAY Annual fee payment

Payment date: 20130724

Year of fee payment: 10

FPAY Annual fee payment

Payment date: 20140724

Year of fee payment: 11

FPAY Annual fee payment

Payment date: 20150724

Year of fee payment: 12

FPAY Annual fee payment

Payment date: 20160722

Year of fee payment: 13

LAPS Lapse due to unpaid annual fee