Event Hubs 실습

Event Hubs 네임스페이스 만들기

NS_NAME=myEvt-HubNs1

az eventhubs namespace create --name $NS_NAME

 

az eventhubs namespace authorization-rule keys list --name RootManageSharedAccessKey --namespace-name $NS_NAME

Event Hubs 네임스페이스에 대한 연결 문자열을 페치합니다. Event Hub를 사용하여 메시지를 보내고 받도록 응용 프로그램을 구성하려면 이 작업이 필요

 

결과조회, 나중에 primaryKey가 sender 소스에 적어야됨

$NS_NAME

{

  "aliasPrimaryConnectionString": null,

  "aliasSecondaryConnectionString": null,

  "keyName": "RootManageSharedAccessKey",

  "primaryConnectionString": "Endpoint=sb://myevy-hubns1.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=JdXBEL2VQdqmfTgH4Z3KMsQML6XNTpFjTSFZYs8qOP0=",

  "primaryKey": "JdXBEL2VQdqmfTgH4Z3KMsQML6XNTpFjTSFZYs8qOP0=",

  "secondaryConnectionString": "Endpoint=sb://myevy-hubns1.servicebus.windows.net/;SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=Gf6+jHO5ZUpOW8wt2hC8Kf/6q0u4Z6UVVr5+egzHtfM=",

  "secondaryKey": "Gf6+jHO5ZUpOW8wt2hC8Kf/6q0u4Z6UVVr5+egzHtfM="

}

 

Event Hub 만들기

HUB_NAME=onestxhub

az eventhubs eventhub create --name $HUB_NAME --namespace-name $NS_NAME

조회는 show

az eventhubs eventhub show --namespace-name $NS_NAME --name $HUB_NAME

 

기본 디폴트 스펙 : 보존기간 7, 파티션수 4




 

 

 

이벤트허브 인스턴스, 개요에서... 확인

 

 

이제 게시자 -- -소비자를 만들어보자

 

--스토리지 생성

az storage account create --name $STORAGE_NAME --sku Standard_RAGRS --encryption blob

--account keys list 명령을 사용하여 저장소 계정과 연결된 모든 액세스 키를 나열

az storage account keys list --account-name $STORAGE_NAME

--연결문자열 보기

az storage account show-connection-string -n $STORAGE_NAME

 

--그 커넥션 스트링 이용하여, 컨테이너 만들때 사용

az storage container create -n messages --connection-string "DefaultEndpointsProtocol=https;EndpointSuffix=core.windows.net;AccountName=onestxstore;AccountKey=py24nMGjV+VEz/NBNypL2Q7Zt7RTeZ9xitpYp3yxHUQj6WV0vIGTkQIYazb6MXDj70OITEPGTATNZN9LMLtusg=="

 

깃 클론명령어로 깃허브 리포짓토리 복제해옴 (자바 소스임)

cd ~

git clone https://github.com/Azure/azure-event-hubs.git

 

 

수정할 페이지 해당 경로로 가서

cd azure-event-hubs/samples/Java/Basic/SimpleSend/src/main/java/com/microsoft/azure/eventhubs/samples/SimpleSend

 

편집기 호출

code .

 편집기에서 다음 문자열을 찾아서 바꿉니다.

• "Your Event Hubs namespace name"을 Event Hub 네임스페이스의 이름으로 바꿉니다.
• "Your Event Hub"를 Event Hub 이름으로 바꿉니다.
• "Your policy name"을 RootManageSharedAccessKey로 바꿉니다.
• "Your primary SAS key"를 이전에 저장한 Event Hub 네임스페이스에 대한 primaryKey 키 값으로 바꿉니다

 

 

이제 mvn 명령을 사용하여 Java 응용 프로그램을 빌드하겠습니다.

1. 기본 SimpleSend 폴더로 다시 변경합니다.
   bash복사
   cd ~/azure-event-hubs/samples/Java/Basic/SimpleSend
2. Java SimpleSend 응용 프로그램을 빌드합니다. 이렇게 하면 응용 프로그램이 Event Hub에 대한 연결 세부 정보를 사용합니다.
   bash복사
   mvn clean package -DskipTests

 

 

이제 수신자 소스 수정

EventProcessorSample.java 편집

EventHubReceiver 및 EventProcessorHost라는 두 개의 메서드를 사용할 수 있습니다.

 

각 연결문자열 값들을 수정해주고 아래와 같은 명령어로 빌드

 

1. 다음 명령을 사용하여 기본 EventProcessorSample 폴더로 변경합니다.
   bash복사
   cd ~/azure-event-hubs/samples/Java/Basic/EventProcessorSample
2. 다음 명령을 사용하여 Java SimpleSend 응용 프로그램을 빌드합니다. 이렇게 하면 응용 프로그램이 Event Hub에 대한 연결 세부 정보를 사용합니다.
   bash복사
   mvn clean package -DskipTests

발신자 및 수신자 앱 시작

3. java 명령을 사용하고 .jar 패키지를 지정하여 명령줄에서 Java 응용 프로그램을 실행합니다. 다음 명령을 사용하여 SimpleSend 응용 프로그램을 시작합니다.
   bash복사
   cd ~/azure-event-hubs/samples/Java/Basic/SimpleSend
   java -jar ./target/simplesend-1.0.0-jar-with-dependencies.jar
4. 보내기 완료... 가 표시되면 ENTER 키를 누릅니다.
   output복사
   jar-with-dependencies.jar
   SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder".
   SLF4J: Defaulting to no-operation (NOP) logger implementation
   SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details.
   2018-09-18T19:42:15.146Z: Send Complete...
5. 다음 명령을 사용하여 EventProcessorSample 응용 프로그램을 시작합니다.
   bash복사
   cd ~/azure-event-hubs/samples/Java/Basic/EventProcessorSample
   java -jar ./target/eventprocessorsample-1.0.0-jar-with-dependencies.jar
6. 메시지가 콘솔에 표시되지 않으면 ENTER 키나 CTRL+C를 눌러서 프로그램을 종료합니다.

 

 

 

 

스토리지 살펴보면

 

해당 값 하나 열어보면 아래와 같은 스펙

 

 

 

 

한번더 실행시키니…

 

 

다시…

이벤트허브 네임스페이스 하위 메트릭에서

 

최근 30분 선택하고,

메트릭 항목중에서 Incoming Message 를 선택하면 200개로 확인됨.

위에서 simplesend 자바 소스를 두번 실행했으니, 200개 전송됨 확인가능