다른 응용 프로그램에서 신경절 정보를 읽는 방법은 무엇입니까?

이에 대한 통찰력을 얻을 수 있도록 도와 드릴 수 있습니다. 하지만 그 전에 저는 Java 프로그래머가 아니라 C / C ++ 프로그래머입니다. 즉, ganglia에서 어떻게 작동하는지 알려줄 수 있으며 Java / Python에서 원하는 코드를 다시 작성하는 동등한 메서드를 찾을 수 있습니다.

원하는 것을 달성하기위한 ganglia에는 API가 없습니다.

먼저 제대로 이해하기 위해 아래의 신경절 설정을 고려하십시오.

GS1과 GS2는 시스템 메트릭스를 수집하여 GM에 푸시하고 있습니다. 따라서 질문에 따라 자체 Java / Python 기반 애플리케이션에서 이러한 모든 메트릭을 수집하려면 마스터 서버에 애플리케이션을 설치해야 할 수 있습니다 (예 : GS를 자신의 애플리케이션으로 대체).

GS1 및 GS2는 수집 된 모든 메트릭을 UDP 유니 캐스트 채널 또는 UDP 멀티 캐스트 채널로 보냅니다. 보다 쉬운 확장 성을 위해 모든 gmond.conf에서 UDP 유니 캐스트를 활성화하는 것이 좋습니다.

귀하의 질문은 GM을 귀하의 도구로 대체하는 것에 관한 것이기 때문에 GS1 및 GS2에 대해서는 많이 논의하지 않을 것입니다.

GM은 UDP 연결을 설정하고 데이터를 자체 판독 가능한 형식으로 변환하기 위해 두 개의 중요한 라이브러리를 많이 사용합니다. UDP 연결을 설정하고 관련 활동을 수행 하는 APR (Apache Portable Runtime)과 네트워크를 통해 데이터를 전송하고 RPC를 수행하는 XDR (External Data Representation)입니다.

먼저 Java 및 Python에서 APR 및 XDR에 해당하는 라이브러리를 찾아야합니다. XDR은 이미 Java에서 사용할 수 있으며 APR은 네트워크 간 작업 (예 : UDP 소켓 생성 등)을 수행하기 위해 자체 기본 구현으로 대체 될 수 있습니다.

ganglia의 gmond.c 소스 파일을 열고 1436 행으로 이동하십시오. C 함수를 찾을 수 있습니다.

static void process_udp_recv_channel(const apr_pollfd_t *desc, apr_time_t now).

이 기능은 기본적으로 "UDP 연결 설정"및 "읽을 수있는 형식으로 데이터 변환"활동을 수행합니다.

위 함수의 호출 흐름은 다음과 같습니다.

이제 더 많은 것을 이해하기 위해 1436 행의 함수를 확장 해 보겠습니다.

이 함수의 첫 번째 인수는 IP, 포트 등과 같은 네트워크 매개 변수를 전달합니다. 구조는 아래에서 확장됩니다. Java에서도 유사한 객체를 찾을 수 있습니다.

struct apr_pollfd_t {
    apr_pool_t *p;              /**< associated pool */
    apr_datatype_e desc_type;   /**< descriptor type */
    apr_int16_t reqevents;      /**< requested events */
    apr_int16_t rtnevents;      /**< returned events */
    apr_descriptor desc;        /**< @see apr_descriptor */
    void *client_data;          /**< allows app to associate context */
};

두 번째 매개 변수는 SFLOW가 비활성화 된 경우 수행 할 작업이 없습니다.

따라서 APR 풀, UDP 연결 등을 만드는 것으로 시작하십시오.

  socket         = desc->desc.s;
  channel       = desc->client_data;

  apr_pool_create(&p, global_context);
  status = apr_socket_addr_get(&remotesa, APR_LOCAL, socket);

  status = apr_sockaddr_info_get(&remotesa, NULL, remotesa->family, remotesa->port, 0, p);

  /* Grab the data */
  status = apr_socket_recvfrom(remotesa, socket, 0, buf, &len);
  if(status != APR_SUCCESS)
    {
      apr_pool_destroy(p);
      return;
    }  

  apr_sockaddr_ip_buffer_get(remoteip, 256, remotesa);

  /* Check the ACL */
  if(Ganglia_acl_action( channel->acl, remotesa) != GANGLIA_ACCESS_ALLOW)
    {
      apr_pool_destroy(p);
      return;
    }

모든 변수 선언은 확장 된 함수의 시작 부분에서 찾을 수 있습니다 (1439 ~ 1456 행).

그런 다음 XDR 스트림을 만듭니다.

xdrmem_create(&x, buf, max_udp_message_len, XDR_DECODE);

메타 데이터 및 메트릭 값을 저장하는 구조체의 데이터를 플러시합니다.

memset( &fmsg, 0, sizeof(Ganglia_metadata_msg));
memset( &vmsg, 0, sizeof(Ganglia_value_msg));

fmsg ( Ganglia_metadata_msg) 및 vmsg ( Ganglia_value_msg) 구조체 정의는 gm_protocol.h 헤더 파일 에서 찾을 수 있습니다 . Java로 다시 작성하십시오.

그런 다음 수신 된 메시지가 "메타 데이터"인지 "메트릭 값"인지 확인합니다.

xdr_Ganglia_msg_formats(&x, &id); // this function is located in the source file gm_protocol_xdr.c and this file is generated by rpcgen.

참고 : rpcgen 은 rpc 컴파일러 이며이 질문 에서 설명을 찾을 수 있습니다 .

참고 : 다음은 gm_protocol_xdr.c에 대한 링크입니다 .

다음 id은 enum이며 그 선언은 다음과 같습니다.

enum Ganglia_msg_formats {
    gmetadata_full = 128,
    gmetric_ushort = 128 + 1,
    gmetric_short = 128 + 2,
    gmetric_int = 128 + 3,
    gmetric_uint = 128 + 4,
    gmetric_string = 128 + 5,
    gmetric_float = 128 + 6,
    gmetric_double = 128 + 7,
    gmetadata_request = 128 + 8,
};
typedef enum Ganglia_msg_formats Ganglia_msg_formats;

의 값에 따라 id, 당신은 패킷이이 값의 종류를 확인할 수 있습니다. 이를 위해이 함수는 다른 함수 (실제로 rpcgen에 의해 생성됨)를 호출하여 패킷에있는 값의 종류를 확인하고 발견되면이를 사람이 읽을 수있는 형식으로도 변환합니다.

기능은 다음과 같습니다.

xdr_Ganglia_value_msg(&x, &vmsg);

이 함수의 전체 확장은 275 행의 gm_protocol_xdr.c 에서 찾을 수 있습니다 .

그런 다음이 패킷으로 원하는 것을 할 수 있습니다.

결국 할당 된 모든 XDR 변수와 APR 풀을 해제해야합니다.

나는 이것이 당신 자신의 응용 프로그램으로 시작하는 공정한 아이디어를 제공하기를 바랍니다.