Demo for Dapr v1.x
1. Demo Services
-
dapr-demo-proto: protocol buffer definition, contains the generated code.
-
dapr-demo-order: product java service, serve on 5050
- provide http method
/createto create a new order.- request dapr-demo-product http
/getto query product service - request dapr-demo-pay grpc
payto pay order
- request dapr-demo-product http
- listen topic
pay_eventin raw data format - listen topic
pay_resultin CloudEvent format
-
dapr-demo-product: product java service, serve on 5051
- provide http method
/getto response product price.
- provide http method
-
dapr-demo-pay: pay java service, serve on 5052
- provide grpc
paymethod to pay an order- publish
payingevent to topicpay_event - request dapr-demo-bank grpc
transto finish a pay transaction
- publish
- listen topic
trans_event- publish
successevent to topicpay_result
- publish
- dapr-demo-bank: bank java service, serve on 5053
- provide grpc
transmethod to finish a pay transaction- publish
successevent to topictrans_event
- publish
- dapr-demo-discount: discount golang service, serve on 5054
2. prepare
The version of protocol buffer and grpc should match the dapr version, which can be found at https://github.com/dapr/java-sdk/blob/master/pom.xml.
- protocol buffer version: 3.13.0
- grpc version: 1.39.0
2.1. install protoc
# ref: https://google.github.io/proto-lens/installing-protoc.html
# ---- mac
# PROTOC_ZIP=protoc-3.13.0-osx-x86_64.zip
# ---- linux
PROTOC_ZIP=protoc-3.13.0-linux-x86_64.zip
curl -OL https://github.com/protocolbuffers/protobuf/releases/download/v3.13.0/$PROTOC_ZIP
sudo unzip -o $PROTOC_ZIP -d /usr/local bin/protoc
sudo unzip -o $PROTOC_ZIP -d /usr/local 'include/*'
sudo chmod +x /usr/local/bin/protoc
rm -f $PROTOC_ZIP
2.2. install protoc-java-plugin
# ref: https://github.com/grpc/grpc-java/tree/master/compiler
# 1. Navigate to https://mvnrepository.com/artifact/io.grpc/protoc-gen-grpc-java
# 2. Click into a version
# 3. Click "Files"
# ---- mac
# wget https://repo1.maven.org/maven2/io/grpc/protoc-gen-grpc-java/1.39.0/protoc-gen-grpc-java-1.39.0-osx-x86_64.exe
# sudo mv protoc-gen-grpc-java-1.39.0-osx-x86_64.exe /usr/local/bin/protoc-gen-grpc-java-1.39.0
# ---- linux
wget https://repo1.maven.org/maven2/io/grpc/protoc-gen-grpc-java/1.39.0/protoc-gen-grpc-java-1.39.0-linux-x86_64.exe
sudo mv protoc-gen-grpc-java-1.39.0-linux-x86_64.exe /usr/local/bin/protoc-gen-grpc-java-1.39.0
sudo chmod +x /usr/local/bin/protoc-gen-grpc-java-1.39.0
2.2. install protoc-golang-plugin
go install google.golang.org/protobuf/cmd/protoc-gen-go@latest
3. generate grpc java code
make proto-gen
4. How To Run
4.1. run dapr demo in self host
50005/tcp dapr_placement
#6ff1e82bd6f1 openzipkin/zipkin "start-zipkin" 2 months ago Up 37 minutes (healthy) 9410/tcp, 0.0.0.0:9411->9411/tcp dapr_zipkin
# 816b739bf523 redis "docker-entrypoint.s…" 2 months ago Up 37 minutes 0.0.0.0:6379->6379/tcp dapr_redis
make build-golang build-java
sh run-self-host.sh
">
# install dapr wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash # or download directly: https://github.com/dapr/cli/releases/download/v1.6.0/dapr_darwin_amd64.tar.gz # dapr uninstall dapr init dapr --version # CLI version: 1.6.0 # Runtime version: 1.6.0 docker ps #CONTAINER ID IMAGE COMMAND CREATED STATUS PORTS NAMES #73627103ac9d daprio/dapr:1.6.0 "./placement" 30 minutes ago Up 30 minutes 0.0.0.0:50005->50005/tcp dapr_placement #6ff1e82bd6f1 openzipkin/zipkin "start-zipkin" 2 months ago Up 37 minutes (healthy) 9410/tcp, 0.0.0.0:9411->9411/tcp dapr_zipkin # 816b739bf523 redis "docker-entrypoint.s…" 2 months ago Up 37 minutes 0.0.0.0:6379->6379/tcp dapr_redis make build-golang build-java sh run-self-host.sh
4.2. run dapr demo in kubernetes
install tools:
# install kubectl
curl -LO "https://dl.k8s.io/release/$(curl -L -s https://dl.k8s.io/release/stable.txt)/bin/linux/amd64/kubectl"
curl -LO "https://dl.k8s.io/$(curl -L -s https://dl.k8s.io/release/stable.txt)/bin/linux/amd64/kubectl.sha256"
echo "$(<kubectl.sha256) kubectl" | sha256sum --check
sudo install -o root -g root -m 0755 kubectl /usr/local/bin/kubectl
kubectl version --client
# install helm
# find the latest version from https://mirrors.huaweicloud.com/helm
wget https://mirrors.huaweicloud.com/helm/v3.7.1/helm-v3.7.1-linux-amd64.tar.gz
tar -xvf helm-v3.7.1-linux-amd64.tar.gz
mv linux-amd64/helm /usr/local/bin/
# https://docs.dapr.io/operations/hosting/kubernetes/cluster/setup-minikube/
curl -LO https://storage.googleapis.com/minikube/releases/latest/minikube-linux-amd64
sudo install minikube-linux-amd64 /usr/local/bin/minikube
minikube config set vm-driver docker
minikube start --cpus=4 --memory=4096
install dapr in kubernetes:
# ----------------------------------
# install dapr cli using command (NOT required if already installed using helm)
wget -q https://raw.githubusercontent.com/dapr/cli/master/install/install.sh -O - | /bin/bash
# The -k flag initializes Dapr on the Kubernetes cluster in your current context.
# Setup & configure mutual TLS: https://docs.dapr.io/operations/security/mtls/
# If custom certificates have not been provided, Dapr will automatically create and persist self signed certs valid for one year. In Kubernetes,
# the certs are persisted to a secret that resides in the namespace of the Dapr system pods, accessible only to them.
dapr init -k --enable-mtls=false
# Uninstall Dapr on Kubernetes with CLI
# dapr uninstall -k
kubectl get pods --namespace dapr-system
dapr status -k
# ----------------------------------
install dapr in kubernetes using helm
install redis:
redis-state.yaml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: statestore
namespace: default
spec:
type: state.redis
version: v1
metadata:
- name: redisHost
value: redis-master.default.svc.cluster.local:6379
- name: redisPassword
secretKeyRef:
name: redis
key: redis-password
EOF
cat < redis-pubsub.yaml
apiVersion: dapr.io/v1alpha1
kind: Component
metadata:
name: pubsub
namespace: default
spec:
type: pubsub.redis
version: v1
metadata:
- name: redisHost
value: redis-master.default.svc.cluster.local:6379
- name: redisPassword
secretKeyRef:
name: redis
key: redis-password
EOF
kubectl apply -f redis-state.yaml
kubectl apply -f redis-pubsub.yaml
kkubectl get components
# NAME AGE
# pubsub 26d
# statestore 26d">
# Install Redis into your cluster helm repo add bitnami https://charts.bitnami.com/bitnami helm repo update helm install redis bitnami/redis # redis-master.default.svc.cluster.local for read/write operations (port 6379) # redis-replicas.default.svc.cluster.local for read-only operations (port 6379) # export REDIS_PASSWORD=$(kubectl get secret --namespace default redis -o jsonpath="{.data.redis-password}" | base64 --decode) # see the Redis containers now running in your cluster kubectl get pods # NAME READY STATUS RESTARTS AGE # redis-master-0 1/1 Running 3 (27m ago) 27d # redis-replicas-0 1/1 Running 5 (27m ago) 27d # redis-replicas-1 1/1 Running 5 (27m ago) 27d # redis-replicas-2 1/1 Running 5 (27m ago) 27d cat <<EOF > redis-state.yaml apiVersion: dapr.io/v1alpha1 kind: Component metadata: name: statestore namespace: default spec: type: state.redis version: v1 metadata: - name: redisHost value: redis-master.default.svc.cluster.local:6379 - name: redisPassword secretKeyRef: name: redis key: redis-password EOF cat <<EOF > redis-pubsub.yaml apiVersion: dapr.io/v1alpha1 kind: Component metadata: name: pubsub namespace: default spec: type: pubsub.redis version: v1 metadata: - name: redisHost value: redis-master.default.svc.cluster.local:6379 - name: redisPassword secretKeyRef: name: redis key: redis-password EOF kubectl apply -f redis-state.yaml kubectl apply -f redis-pubsub.yaml kkubectl get components # NAME AGE # pubsub 26d # statestore 26d
build demo docker images:
# ---------- MUST execute before eval minikube docker-env
docker run --rm -v $(pwd):/projectdir \
-v ${GOPATH}/src:/go/src \
-v ${GOPATH}/pkg:/go/pkg \
-w /projectdir \
-e GOOS="linux" \
-e GOARCH="amd64" \
-e CGO_ENABLED=0 \
-e GOPROXY=https://goproxy.cn \
golang:1.17.3-buster \
make build-golang
docker run --rm -v $(pwd):/projectdir \
-v ~/.m2:/root/.m2 \
-w /projectdir \
maven:3-openjdk-11 \
mvn clean package
using packages build in previous step to build docker images:
# use minikube docker registry
eval $(minikube -p minikube docker-env)
# build project images
make build-docker
run demo in kubernetes:
sh run-in-kubernetes.sh
53 Oct 20, 2022
7 Dec 3, 2021
4 Jan 13, 2022
2 Dec 14, 2021
9 Nov 23, 2022
382 Jan 1, 2023
6 Oct 19, 2022
4 Sep 13, 2022
5 Aug 30, 2022
98 Jan 7, 2023