ROS 미들웨어를 통한 프로세스 간 통신 구현하기

728x90

ROS 미들웨어를 통한 프로세스 간 통신 구현하기

개요

로봇 운영 체제(ROS, Robot Operating System)는 로봇 소프트웨어를 개발할 때 널리 사용되는 미들웨어 프레임워크입니다. ROS는 다양한 프로세스 간 통신을 효과적으로 지원하며, 이러한 기능은 로봇 소프트웨어의 모듈화와 상호 작용을 가능하게 합니다. 이 글에서는 ROS 미들웨어를 사용하여 프로세스 간 통신을 구현하는 방법에 대해 상세히 설명하겠습니다.

ROS 미들웨어의 기본 개념

ROS 미들웨어는 로봇 소프트웨어 개발에서 핵심적인 역할을 하며, 프로세스 간의 메시지 교환을 관리합니다. ROS의 주요 개념은 다음과 같습니다:

노드(Node): ROS에서 작업을 수행하는 기본 단위입니다. 각 노드는 독립적으로 실행되며, 특정 기능을 담당합니다. 예를 들어, 센서 데이터를 수집하거나 모터를 제어하는 노드가 있을 수 있습니다.
토픽(Topic): 노드 간의 비동기식 메시지 전달을 위한 통로입니다. 노드는 데이터를 발행(publish)하거나 구독(subscribe)할 수 있습니다. 예를 들어, 카메라 노드는 이미지 데이터를 특정 토픽에 발행하고, 다른 노드는 이 토픽을 구독하여 이미지를 처리할 수 있습니다.
서비스(Service): 요청-응답 패턴을 지원하는 동기식 통신 방법입니다. 노드는 서비스 요청을 수신하고 응답을 반환할 수 있습니다. 예를 들어, 로봇의 상태를 질의하고 응답을 받는 서비스가 있습니다.
액션(Action): 긴 작업을 수행하기 위한 인터페이스로, 작업의 진행 상황을 모니터링할 수 있습니다. 액션은 작업 시작, 진행 상태, 완료 등의 정보를 제공합니다.

ROS에서 프로세스 간 통신 구현

프로세스 간 통신을 구현하기 위해 ROS의 노드, 토픽, 서비스, 액션을 활용할 수 있습니다. 여기서는 ROS의 가장 기본적인 통신 방식인 토픽을 중심으로 설명하겠습니다.

1. ROS 패키지 설정

ROS에서는 모든 기능이 패키지 형태로 제공됩니다. 패키지를 생성하고 필요한 종속성을 설정하는 것이 첫 번째 단계입니다.

cd ~/catkin_ws/src
catkin_create_pkg my_package std_msgs rospy

위 명령어는 my_package라는 이름의 패키지를 생성하며, std_msgs와 rospy를 종속성으로 포함합니다. std_msgs는 표준 메시지 유형을 제공하고, rospy는 Python에서 ROS 기능을 사용할 수 있게 해줍니다.

2. 노드 작성

노드는 독립적으로 동작하는 프로세스입니다. 여기서는 Python을 사용하여 토픽을 발행하고 구독하는 간단한 예제를 보여드리겠습니다.

발행자 노드 (Publisher)

my_package/src/talker.py 파일을 생성하고 아래와 같이 작성합니다:

#!/usr/bin/env python

import rospy
from std_msgs.msg import String

def talker():
rospy.init_node('talker', anonymous=True)
pub = rospy.Publisher('chatter', String, queue_size=10)
rate = rospy.Rate(10)  # 10hz
while not rospy.is_shutdown():
hello_str = "hello world %s" % rospy.get_time()
rospy.loginfo(hello_str)
pub.publish(hello_str)
rate.sleep()

if __name__ == '__main__':
try:
talker()
except rospy.ROSInterruptException:
pass

이 노드는 chatter라는 이름의 토픽에 문자열 메시지를 발행합니다. rospy.init_node는 노드를 초기화하고, rospy.Publisher는 토픽을 생성하여 메시지를 발행합니다. rate.sleep()은 루프를 10Hz 주기로 실행합니다.

구독자 노드 (Subscriber)

my_package/src/listener.py 파일을 생성하고 아래와 같이 작성합니다:

#!/usr/bin/env python

import rospy
from std_msgs.msg import String

def callback(data):
rospy.loginfo("I heard %s", data.data)

def listener():
rospy.init_node('listener', anonymous=True)
rospy.Subscriber('chatter', String, callback)
rospy.spin()

if __name__ == '__main__':
listener()

이 노드는 chatter 토픽에서 발행된 메시지를 수신하여 로그로 출력합니다. rospy.Subscriber는 토픽을 구독하고, callback 함수는 메시지를 처리합니다. rospy.spin()은 노드를 계속 실행 상태로 유지합니다.

3. 실행

ROS 패키지를 빌드하고 노드를 실행합니다:

cd ~/catkin_ws
catkin_make
source devel/setup.bash
roscore

새 터미널에서:

source ~/catkin_ws/devel/setup.bash
rosrun my_package talker.py

또 다른 터미널에서:

source ~/catkin_ws/devel/setup.bash
rosrun my_package listener.py

위 명령어는 talker와 listener 노드를 실행하여 chatter 토픽을 통해 메시지를 교환합니다.

문제와 해결책

ROS에서 프로세스 간 통신을 구현할 때 몇 가지 문제가 발생할 수 있습니다. 아래는 일반적인 문제와 해결책입니다.

1. 노드가 서로 통신하지 않음

노드가 서로 통신하지 않는 경우, 가장 먼저 확인해야 할 것은 ROS 마스터의 주소입니다. ROS_MASTER_URI 환경 변수가 올바르게 설정되어 있는지 확인합니다. 일반적으로 로컬 환경에서 작업할 경우, http://localhost:11311으로 설정되어야 합니다.

export ROS_MASTER_URI=http://localhost:11311

또한, 네트워크 문제로 인해 노드 간의 통신이 실패할 수도 있습니다. 이 경우, 네트워크 설정을 점검하고, 노드가 실행되고 있는 호스트 간의 네트워크 연결을 확인합니다.

2. 토픽 메시지가 전달되지 않음

토픽 메시지가 전달되지 않는 경우, 발행자와 구독자가 동일한 메시지 타입을 사용하는지 확인합니다. 메시지 타입이 일치하지 않으면 메시지가 전달되지 않습니다. std_msgs/String과 같은 표준 메시지 타입을 사용할 때는 주의가 필요합니다.

또한, 메시지 큐의 크기(queue_size)가 너무 작거나 너무 클 경우 문제가 발생할 수 있습니다. 적절한 큐 크기를 설정하여 메시지 손실을 방지합니다.

3. 노드가 비정상적으로 종료됨

노드가 비정상적으로 종료되는 경우, rospy.ROSInterruptException을 사용하여 예외 처리를 추가하는 것이 좋습니다. 또한, 코드 내에서 자원을 적절히 해제하고, 예외 상황을 처리하여 안정성을 높입니다.

결론

ROS 미들웨어를 활용한 프로세스 간 통신 구현은 로봇 소프트웨어 개발에서 매우 중요한 기술입니다. 노드, 토픽, 서비스, 액션과 같은 ROS의 기본 개념을 이해하고 이를 활용하여 효과적으로 통신을 구현할 수 있습니다. 위의 예제와 설명을 통해 기본적인 통신 방법을 익히고, 실제 개발 환경에서 적용해보세요.

참고 문헌 및 링크: