728x90
반응형
728x90
반응형
반응형

환경: windows11, springboot2.7.6, java17

 

2024.02.12 - [서버 세팅 & tool/docker] - [windows] 네트워크 세팅, rabbitmq 세팅, config server 세팅

 

[windows] 네트워크 세팅, rabbitmq 세팅, config server 세팅

환경: windows11, springboot2.7.6, java17 2024.02.10 - [서버 세팅 & tool/docker] - [windows] docker 이미지 만들고 올리고 실행 [windows] docker 이미지 만들고 올리고 실행 환경: windows11, 아래 설치 진행 2024.02.10 - [서버

bangpurin.tistory.com

 

eureka discovery service를 도커에 배포하기

1. Dockerfile 생성

FROM openjdk:17-ea-slim-buster
VOLUME /tmp
COPY target/discoveryservice-1.0.jar discoveryservice.jar
ENTRYPOINT ["java", "-jar", "discoveryservice.jar"]

 

2. 도커이미지 생성

 mvn clean compile package -DskipTests=true
 docker build -t haileyjhbang/discovery-service:1.0 .  //도커이미지생성

도커 이미지 생성 확인 

 

3. 레파지토리 푸시

도커 이미지를 허브 사이트에 올려보기

docker push haileyjhbang/discovery-service:1.0

 

4. 도커 실행

해당 config server 정보는 도커에서는 다르게 적용되어야 하므로 실행 시 정보 추가 필요

docker run -d -p 8761:8761 --network ecommerce-network \
 -e "spring.cloud.config.uri=http://config-service:8888" \
 --name discovery-service haileyjhbang/discovery-service:1.0
 //포트 포워딩; 네트워크 설정
 //설정 추가; 같은 네트워크로 묶여있기 때문에 컨테이너 이름을 명시해도 문제없음
 //네임, 이미지 이름 명시

 

5. 상태 확인 및 추가 기동

4번처럼 실행하고 도커 상태를 보면 다른 것들은 죽어있는 상태

네트워크 상태를 봐도 죽어있음

docker network inspect ecommerce-network

 

그래서 아래처럼 추가 기동 해줌

다시 상태를 확인해 보면 다 떠있음 

로컬에서 유레카 확인

728x90
반응형
반응형

환경: windows11, springboot2.7.6, java17

2024.02.10 - [서버 세팅 & tool/docker] - [windows] docker 이미지 만들고 올리고 실행

 

[windows] docker 이미지 만들고 올리고 실행

환경: windows11, 아래 설치 진행 2024.02.10 - [서버 세팅 & tool/docker] - [windows] docker; 컨테이너 가상화 [windows] docker; 컨테이너 가상화 virtualization 물리적인 컴퓨터 리소스를 다른 시스템이나 애플리케이

bangpurin.tistory.com

 

docker networks

bridge network

docker network create --driver bridge 브릿지이름
docker network is

host network

  • 네트워크를 호스트로 설정하면 호스트의 네트워크 환경을 그대로 사용 가능
  • 포트 포워딩 없이 내부 애플리케이션 사용

none network

  • 네트워크 사용하지 않음
  • IO네트워크만 사용, 외부와 단절

네트워크 세팅

docker desktop을 실행하여 docker daemon을 실행하고 초기화

docker container ls -a // 꺼진 컨테이너들까지 확인
docker system prune // 이미지와 남는 것들 까지 다 삭제

 

docker network create --gateway 172.18.0.1 --subnet 172.18.0.0/16 ecommerce-network
// docker network create ecommerce-network
// gateway와 subnet 정보를 안주면 랜덤으로 되긴하는데 설정해주는게 관리가 편함
// 이름은 꼭 주도록; 그러면 ip가 바뀌어도 이름으로 접근가능
docker network ls
// 네트워크 리스트
docker network inspect 네트워크이름
// 네트워크 상세 정보

 

rabbitmq 도커 세팅

docker run -d --name rabbitmq --network ecommerce-network \
 -p 15672:15672 -p 5672:5672 -p 15671:15671 -p 5671:5671 -p 4369:4369 \
 -e RABBITMQ_DEFAULT_USER=guest \
 -e RABBITMQ_DEFAULT_PASS=guest rabbitmq:management
 
 //도커를 백그라운드에서 돌리고 이름을 부여하고 특정 네트워크 안에서 돌 수 있게 지정
 //rabbitmq 내부에서 사용하는 포트 포워딩
 //환경변수
 //이미지 이름이 rabbitmq:management

run으로 실행하면 기존에  rabbitmq:management 라는 이미지가 없으므로 다운로드하는 작업이 포함됨

실행 후 네트워크 안에 잘 포함되었는지 확

port forwarding

잘 떴는지 확인

 

configuration service 도커화

기존에 사용하던 암호화 키파일 확인

jks 파일을 복사하여 프로젝트 루트로 붙여 넣고 Dockerfile 작성

FROM openjdk:17-ea-slim-buster
VOLUME /tmp
COPY apiEncryptionKey.jks apiEncryptionKey.jks
COPY target/config-server-1.0.jar config-server.jar
ENTRYPOINT ["java", "-jar", "config-server.jar"]

해당 파일 경로가 바뀌고 remote에서는 본 파일로 실행해야 하기 때문에 아래처럼 설정파일 경로도 수정해야 함.

참고로 맥에서는 file:/ 의 슬래시도 지워야 된다는 말이 있는데 나는 우선 이걸로 성공..

jar 파일 빌드

 mvn clean compile package -DstkpTests=true

도커 빌드; 현재 디렉터리 안에서 실행한다는 의미의 점 꼭..!

docker build -t haileyjhbang/config-service:1.0 .

기존 application.yml 설정을 확인해 보면 rabbitmq 설정이 로컬 테스트용으로 되어있음. 이를 도커에 그대로 올리면 당연히 안될 거고 도커의 rabbitmq로 바꿔줘야 함.

물론 설정 자체를 수정(docker ip를 넣고 저장)해서 그대로 jar을 말아줄 수도 있지만, docker ip는 바뀔 수 있음. 따라 jar는 그대로 말고 실행 시 도커의 이름으로 주입해 주는 게 편함.

docker run -d -p 8888:8888 --network ecommerce-network \
 -e "spring.rabbitmq.host=rabbitmq" \
 -e "spring.profiles.active=default" \
  --name config-service haileyjhbang/config-service:1.0
  // 포트 포워딩, 기존의 네트워크 안에 포함
  // 설정 변경사항 추가
  // 이름 주고 이미지 주고

실행 후 네트워크 검사하면 3번으로 실행됨 

docker network inspect ecommerce-network

잘 떠있는지 로그 확인

docker logs config-service

에러가 있음

Unsatisfied dependency expressed through method 'searchPathCompositeEnvironmentRepository' parameter 0; nested exception is org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'defaultEnvironmentRepository' defined in class path resource [org/springframework/cloud/config/server/config/DefaultRepositoryConfiguration.class]: Invocation of init method failed; nested exception is java.lang.IllegalStateException: You need to configure a uri for the git repository.

??

git repository 설정하라는 이상한 에러.

구글링 해보니 property 옵션을 native로 주라고.. 하여 native로 시작해 봄.

docker run -d -p 8888:8888 --network ecommerce-network -e "spring.rabbitmq.host=rabbitmq" -e "spring.profiles.active=native" --name config-service haileyjhbang/config-service:1.0

성공..?

그러나 서버는 잘 뜨지만, 설정파일을 잘 읽어오지 못하는 문제가 생긴다.

왜냐면.. search-location 이 위처럼 로컬 경로이기 때문..

그래서 다시 git 정보를 가져오도록 주석을 해제한다. native이면 native.search-locations를 따라가는 것 같고 default 면 git을 바라보는 듯..

 

프로퍼티 수정 후 다시 mvn compile 하고 docker build 하고 run 하면 아래처럼 잘 나온다.

 url의 대소문자 주의..

728x90
반응형
반응형

환경: windows11, 아래 설치 진행

2024.02.10 - [서버 세팅 & tool/docker] - [windows] docker; 컨테이너 가상화

 

[windows] docker; 컨테이너 가상화

virtualization 물리적인 컴퓨터 리소스를 다른 시스템이나 애플리케이션에서 사용할 수 있도록 제공 플랫폼 가상화 리소스 가상화 하이퍼바이저(hypervisor) Virtual machine manager(VMM) 다수의 운영체제를

bangpurin.tistory.com

도커 기본 명령어

docker run -d -p 3306:3306 -e MYSQL_ALLOW_EMPTY_PASSWORD=true --name mysql mysql:5.7
//도커로 mysql:5.7을 백그라운드로 실행하는데 
//포트 포워딩으로 호스트의 3306이랑 도커의 3306이랑 연결
//mysql5.7실행 시 필요한 설정을 -e옵션으로 주고
//이름을 mysql로 설정(아니면 랜덤)

실행 확인

docker ps -a

백그라운드라 로그가 안뜨는데, 지나간 로그를 보려면

docker logs 이름/컨테이너id

잘 뜬건 확인했고 terminal로 실행하려면

 docker exec -it mysql /bin/bash

그러면 터미널로 붙어서 쓰는것과 동일한 효과

여기서  mysql -uroot -p -h127.0.0.1 써서 접속해서 디비 사용하면 됨

삭제 시 중지하고 삭제 해야 

 

서비스를 jar이미지 만들어보기

0. 사용하고자 하는 이미지가 있으면 docker hub에서 확인

1. 아래 경로에 Dockerfile 작성

1-1. Dockerfile 내용물

FROM openjdk:17-ea-slim-buster
VOLUME /tmp
COPY target/user-service-0.0.1-SNAPSHOT.jar user-service.jar
ENTRYPOINT ["java", "-jar", "user-service.jar"]

2. 빌드

1. jar 최신화; Dockerfile 과 동일한 이름으로 jar 생성되었는지 확인 

 mvn clean compile package -DskipTests=true

2. 이미지 올릴 나의 docker hub 계정 확인

3. docker 이미지 만들라는 명령어 실행

맨 마지막에 . 찍어서 현재 폴더임을 나타냄 

 docker build --tag haileyjhbang/user-service:1.0 .

4. repository에 push

docker push haileyjhbang/user-service:1.0

1.0 태그 안주면 latest 를 찾기 때문에 에러가 남 

5. repository 확인 

 

만든 이미지 설치

1. 기존 이미지 삭제(확인 용)

docker rmi 4c828476b26a

2. 이미지 id로 삭제

 docker pull haileyjhbang/user-service:1.0

3. 실행

docker run haileyjhbang/user-service:1.0

728x90
반응형
반응형

환경: windows11

 

virtualization

  • 물리적인 컴퓨터 리소스를 다른 시스템이나 애플리케이션에서 사용할 수 있도록 제공
  • 플랫폼 가상화
  • 리소스 가상화

하이퍼바이저(hypervisor)

  • Virtual machine manager(VMM)
  • 다수의 운영체제를 동시에 실행하기 위한 논리적 플랫폼
  • type1(native / bare metal): 하드웨어에 직접 하이퍼바이저를 설치해서 가상화 운영
  • type2(hosted): 하드웨어 위에 os가 있고 그 위세 하이퍼바이저를 설치해서 가상화 운영
    • 보통 사용 방식

OS virtualization; os 가상화

  • host os 위에 guest os 전체를 가상화
  • VMware, VirtualBox
  • 자유도가 높으나 시스템에 부하가 많고 느려
  • 여러 vm을 띄우면 중복적인 리소스가 반복적으로 사용하게 될 수도 있음 

container virtualization; 컨테이너 가상화

  • host os가 가진 리소스를 적게 사용하며 필요한 프로세스 실행
  • 최소한의 라이브러리와 도구만 포함
  • container의 생성 속도 빠름
  • 중복 리소스 제거 가능. 도커 엔진이 가진 리소스 사용

컨테이너 이미지

  • 컨테이너 실행에 필요한 설정 값 모두
  • 이미지 안에 의존성을 이미 다 가지고 있기 때문에 별도 설치할게 없음 
  • 이미지를 가지고 실체화 한 것이 컨테이너 
  • 이미지 저장소: registry
    • public registry: docker hub
    • private registry 운영 가능 
  • 도커 호스트: 이미지를 실행할 수 있는 곳; 레지스트리에서 다운로드한 이미지를 실행 
    • run: create + start

dockerfile

  • 도커 이미지를 생성하기 위한 스크립트 파일 
  • 자체 문법 DSL(domain specific language) 언어 사용하여 이미지를 생성하기 위한 과정을 기술 
  • docker desktop -> docker container 사용

docker desktop download

docker cmd를 사용하기 위해서는 docker desktop을 실행하여 docker daemon을 실행하여야 함

run 해보고 이상없는지 확인하기 위해 아무 cmd 열어서 아래 명령어 입력

docker info

현재 docker가 가지고 있는 image 확인

docker image ls

현재 docker실행중인 container

docker container ls

명령어

  • create
  • start 실행
  • run = create + start 이미지 없으면 다운로드까지
  • tag: version같은 것; 혹은 용도별 마킹/없으면 자동으로 lastest
  • --name 이름 안 넣으면 랜덤 하게 됨; 중복 안됨, --rm 컨테이너 stop 하고 나서, -it iternative terminal,  --link....
  • 호스트=pc 

 

https://hub.docker.com/

 

Docker Hub Container Image Library | App Containerization

Increase your reach and adoption on Docker Hub With a Docker Verified Publisher subscription, you'll increase trust, boost discoverability, get exclusive data insights, and much more.

hub.docker.com

도커 이미지 관리; 다운로드 가능

docker pull ubuntu:16.04 //down
docker images | grep 16.04 //검색
docker run ubuntu:16.04 //실행 but 바로 종료
docker ps // 도커 컨테이너 실행중인것 확인
docker container ls -a //전체 히스토리 확인
docker container rm 컨테이너ID //컨테이너 삭제
728x90
반응형
반응형

환경: windows11, springboot2.7.6, java17

 

prometheus(저장 서버)

  • metrics를 수집하고 모니터링 및 알람에 사용되는 오픈소스 애플리케이션
  • 시간순으로 데이터가 남음(time series database; TSDB)
  • pull 방식의 구조와 다양한 metric exporter 제
  • 시계열 DB에 metrics 저장 -> 조회가능(query)

grafana(시각화)

  • 데이터 시각화, 모니터링 및 분석을 위한 오픈소스 애플리케이션
  • 시계열 데이터를 시각화하기 위한 대시보드 제공

 

prometheus 다운로드

https://prometheus.io/download/

 

os에 맞는 파일을 다운로드하고 압축을 푼다.

1. 폴더 안의 prometheus.yml 수정하여 수집하고자 하는 서비스를 등록 

8000번은 gateway

2. prometheus 실행 

9090포트로 실행됨

http://localhost:9090/graph

 

grafana 다운로드

https://grafana.com/grafana/download?platform=windows

 

os에 맞는 파일을 다운로드하고 압축을 푼다.

bin 폴더 안에 grafana-server.exe파일 실행(공식 문서에서 실행 가이드 확인)

http://localhost:3000/ (admin / admin으로 로그인)

 

연동

grafana 로그인 후

save & test 클릭

이미 다른사람들이 만들어 놓은 dashboard 불러오기

 

아래 사이트 방문하여 대시보드 다운로드

https://grafana.com/grafana/dashboards/?pg=docs-grafana-latest-dashboards

id를 복사하여 아래 창의 id 넣는 부분에 붙여 넣기 하면 import 가능 

아까 등록한 prometheus 선택하고 import

아래는 대표적인 대시보드

https://grafana.com/grafana/dashboards/3662-prometheus-2-0-overview/

https://grafana.com/grafana/dashboards/4701-jvm-micrometer/

https://grafana.com/grafana/dashboards/11506-spring-cloud-gateway/

 

import 후 metrics 설정을 다시 해야 제대로 된 결과가 나온다. 각 그래프를 edit 하여 지표를 최신화한다.

sum 부분에는 prometheus 에서 검색가능한 지표를 넣어야 하고

job 부분에는 아까 prometheus.yml 에 넣은 job name을 써야 한다.

비슷한 지표를 찾기위해 지구본으로 검색해야한다.. 매 버전?마다 다른 것 같다.

여기에 없는 것도 되긴 함.. 따로 찾아봐야 할 듯.

프로메테우스 서버 설정 참고

 

되는 거 하나.. 이거 설정하고 관련 서비스 api 몇 번 쏘고 새로고침하니까 나온다..

spring_cloud_gateway_requests_seconds_count{outcome="SUCCESSFUL", routeId=~"user-service", job=~"apigateway-service"}

728x90
반응형
반응형

2024.02.04 - [서버 세팅 & tool/kafka] - [windows] kakfa connect; mariadb 설치

사용하게 된 배경: 기존의 서버가 h2 디비를 사용하여 1 인스턴스 - 1 디비를 사용하고 있었는데, 이렇게 되면 여러 인스턴스를 띄울 때 디비가 분리되어 있어서 디비 싱크가 안 맞는 문제가 발생. 그래서 그 h2 디비를 사용하지 않고 kafka source/sink connect를 이용하여 kafka에 연결된 maria 디비(단일 디비)로 사용하려는 것.

 

connect source -> connect sink 연동하기 (db to db)

kafka source connect 추가; 마리아디비 사용

connect source는 8083 포트 사용

echo '{
"name" : "my-source-connect",
"config" : {
	"connector.class" : "io.confluent.connect.jdbc.JdbcSourceConnector",
	"connection.url":"jdbc:mariadb://localhost:3306/mydb",
	"connection.user":"root",
	"connection.password":"1234",
	"mode": "incrementing",   //id 자동 증가
	"incrementing.column.name" : "id",
	"table.whitelist":"users",  // 변경사항 감지할 테이블
	"topic.prefix" : "my_topic_", //저장할 곳의 prefix
	"tasks.max" : "1"
	}
}

' | curl -X POST -d @- http://localhost:8083/connectors --header "content-Type:application/json"

데이터 전달 후 

상세를 확인해 봤는데.. 에러가 났었음

kafka connect 쪽 로그를 보니 같은 테이블 명이 여러 개라고..

 다른 데이터베이스에 있더라도 같은 이름의 테이블이면 안되는 듯..

테이블명을 바꾸거나 아래처럼 수정

다시 상태 확인 시 정상

 

이제 users 테이블에 데이터를 넣어주면 kafka에 해당 topic이 생긴 것을 확인할 수 있다.

consumer 도 확인해 보면 아래처럼 하나 추가된 것 확인

이 상태에서 insert 한번 더 해주면 consumer에 바로 다음 데이터가 추가되는 것을 볼 수 있다.

이 json을 포매터로 확인해 보면 다음과 같다.

fields에 필드에 대한 설명이 있고 payload에 실제 데이터가 들어있다. 나중에 topic을 이용하여 디비에 데이터를 저장하려고 하면 아래 포맷처럼 전달하여야 한다.

kafka sink connect 추가

echo '{
"name":"my-sink-connect",
"config":{
	"connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
	"connection.url":"jdbc:mariadb://localhost:3306/mydb",
	"connection.user":"root",
	"connection.password":"1234",
	"auto.create":"true",  //디비와 연결하는데, 토픽과 같은 테이블 쓰겠다는 의미
	"auto.evolve":"true",
	"delete.enabled":"false",
	"tasks.max":"1",
	"topics":"my_topic_users"  //여기랑 연결
	}
}

'| curl -X POST -d @- http://localhost:8083/connectors --header "content-Type:application/json"

sink connect 생성 확인

이 상태에서 디비에 my_topic_users라는 sink table이 잘 생성되었는지 확인

이후에 users에 데이터를 입력하면 자동으로 my_topic_users에도 똑같이 쌓이는 것 확인

consumer 로그에도 해당 로그 잘 쌓임

디비에 직접 데이터를 추가하는 것 말고도 producer에 위 포맷으로 데이터를 전송하면 동일한 효과를 낼 수 있다.

이후에 users 테이블을 확인하면 해당 데이터는 없고, my_topic_users 테이블 확인하면 있는 것을 확인.

users(source) -> my_topic_users(sink) 테이블의 방향으로 연결되어 있는데, 이번에는 producer를 통해 직접 my_topic_users에 넣어줬으니 users 테이블에는 없는 것.

728x90
반응형

'서버 세팅 & tool > kafka' 카테고리의 다른 글

[windows] kakfa connect; mariadb 설치  (0) 2024.02.04
[windows] kafka 실행  (0) 2024.02.04
반응형

환경: windows11, java17, springboot2.7.6

 

kakfa connect를 통해 데이터를 import/export 가능

코드 없이 configuration으로 데이터 이동 가능

Standalone mode, distribution mode 지원

  • restfult API 지원
  • stream, batch 형태로 데이터 전송 가능
  • 커스텀 connector를 통한 다양한 플러그인 제공(파일, mysql, 등)

 

테스트를 위한 mariaDB 다운로드(in windows)

참고로 마리아디비는 mysql과 코어를 같이 사용한다.

디비 생성을 위해 cmd로 접근

소스에 아래 추가

<dependency>
    <groupId>org.mariadb.jdbc</groupId>
    <artifactId>mariadb-java-client</artifactId>
    <version>3.1.4</version>
</dependency>

소스 띄우고 h2 콘솔로 아래 입력

cool


MariaDB 설치

MacOS

$ brew install mariadb

시작, 종료, 상태확인

$ mysql.server start, mysql.server stop, mysql.server status

접속

$ mysql –uroot

데이터베이스 생성

mysql> create database mydb;

Access denied 발생 시

$ sudo mysql –u root

mysql> use mysql;

mysql> select user, host, plugin FROM mysql.user;

mysql> set password for 'root'@'localhost'=password('test1357’);

mysql> flush privileges;

Windows)

다운로드

mariadb-10.5.8-winx64.zip 파일 다운로드

데이터베이스 초기화

.\bin\mariadb-install-db.exe 

    --datadir=C:\Work\mariadb-10.5.8-winx64\data 

    --service=mariaDB 

    --port=3306 

    --password=test1357


kafka connect 다운로드

http://packages.confluent.io/archive

들어가서 confluent community 7.5.3.zip 다운로드, 압축 해제

 

jdbc connector 다운로드

https://www.confluent.io/hub/confluentinc/kafka-connect-jdbc

 

kafka connect 실행

에러 발생 시 아래처럼 실행 파일 수정

마리아 디비 jar 파일을 kafka connect 폴더 아래로 이동

다시 실행. 그래도 에러

해당경로에 프로퍼티 파일이 없어서 나는 에러로 bat파일을 열어 경로 수정한다.

그리고 다시 실행하면 성공.

성공 후 토픽 리스트를 다시 조회하면, kafka connect 가 필요한 토픽이 추가된 것을 확인할 수 있다.

 

728x90
반응형

'서버 세팅 & tool > kafka' 카테고리의 다른 글

[windows] kakfa connect 연동  (0) 2024.02.04
[windows] kafka 실행  (0) 2024.02.04
반응형

환경: 윈도우11, kafka2.13-3.6.1

 

카프카는 공홈에서 받아주고, 압축을 풀어준다.

카프카/주키퍼 실행 시 아래와 같은 에러 발생한다.

확인해보니 kafka-server-start.bat실행 시 같은 폴더 안에 있는 kafka-run-class.bat를 참조하여 같이 실행시키는데 여기서 너무 많은 classpath를 호출하여 문제가 생기는 것. 윈도우 cmd는 명령줄에 8192글자까지 제한된다고 함..

 

해결방법은 보통 아래와 같이 두가지 방법이 있는 것 같은데,  실행 파일을 수정해 봤는데도 에러가 났음..

  1. kafka 폴더를 C드라이브 바로 밑으로 옮긴후에 실행 + 폴더명 변경
  2. 실행파일 수정

https://stackoverflow.com/questions/48834927/the-input-line-is-too-long-when-starting-kafka/50168530#50168530

 

The input line is too long when starting kafka

I'm trying to run Kafka message queue on Windows. I'm usin this tutorial - https://dzone.com/articles/running-apache-kafka-on-windows-os When i try to run it with comand - .\bin\windows\kafka-ser...

stackoverflow.com

 

그래서 우선 폴더를 C > Program files 아래에 두고, 파일 이름까지 바꿨는데도 또 에러 발생.

진짜 개복치

그래서 C > windows 아래로 옮겼더니 된다.. 진짜 말이 되나

주키퍼 포트: 2181

카프카 포트: 9092

 

 

카프카가 제공하는 샘플 데이터 producer/consumer

토픽에 데이터를 쌓아두면 그걸 구독하는 컨수머가 가져가는 방식

9092 카프카 서버에 토픽 생성; 멀티 클러스터링 시 파티션 값 사용 

windows의 경우 아래 명령어의 .sh 대신 .bat로 바꿔서 실행해야 함!

메시지 생산

$KAFKA_HOME/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic quickstart-events

메시지 소비

$KAFKA_HOME/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic quickstart-events --from-beginning

 

실제 실행 시..

728x90
반응형

'서버 세팅 & tool > kafka' 카테고리의 다른 글

[windows] kakfa connect 연동  (0) 2024.02.04
[windows] kakfa connect; mariadb 설치  (0) 2024.02.04
반응형

환경: windows11 프로, 64비트

 

윈도우에서 rabbitmq 설치 시 erlang을 필수로 설치해야한다.

딱히 호환되는 버전 지정 없이, 최신버전들로 설치해도 문제없다.

 

powershell 관리자 권한 실행

  • ctrl + r 
  • powershell 입력
  • ctrl + shift + enter

명령어

관리자 권한 필요: rabbitmq-service stop, rabbitmq-service start

 

특이사항

윈도우에서 설치하고 GUI(화면)로 관리하려면 rabbitmq_management라는 플러그인을 enable 시켜야하고, 그 후에는 위 명령어로 서비스 재시작을 해야한다.

또한 해당 GUI를 확인하기 위해 인터넷 창에서 http://127.0.0.1:15672/#/를 실행할 경우, 실행되지 않는데,,

아래처럼 윈도우 방화벽을 열어야 한다. 세상에..

https://velog.io/@yeseong31/RabbitMQ-%EC%84%A4%EC%B9%98-%EB%B0%8F-%EC%8B%A4%ED%96%89

 

velog

 

velog.io

 

rabbitmq는 시스템 기동 시 같이 실행되기 때문에 서비스 화면에서 떠있는지 확인하면 된다.

728x90
반응형
반응형

환경: 윈도우, maven 3.8이 설치되어 있음

 

터미널로 실행하는 명령어

pom.xml 이 있는 폴더로 가서 아래와 같이 명령어를 주면 실행된다.

mvn spring-boot:run
# 추가적으로 포트를 수정해야한다면
mvn spring-boot:run -D"spring-boot.run.jvmArguments"='-Dserver.port=9003'

 

맥의 경우 옵션값에 큰따옴표(")를 안 해줘도 되는 것 같은데 윈도우에서는 위처럼 스트링 처리를 해줘야 한다..

안 그러면 아래 에러를 만남..

 Unknown lifecycle phase ".run.jvmArguments=-Dserver.port=9003". You must specify a valid lifecycle phase or a goal in the format

 

+ 수동으로 jar 파일 실행 시에도 큰따옴표 .. 해줘야 한다.

 java -jar -D"server.port=9092" .\second-service-0.0.1-SNAPSHOT.jar

 

하나의 소스로 여러 인스턴스 띄우기

server:
  port: 0

스프링 부트 프로젝트의 포트를 0으로 지정하면 랜덤포트 사용인데

이렇게 하면 여러 번 실행 시 각기 다른 포트로 떠서 여러 인스턴스를 띄울 수 있다.

728x90
반응형

+ Recent posts