Dapr学习日记2

落日映苍穹つ 2022-10-13 01:54 149阅读 0赞

**1.继承AppCallback.AppCallbackBase**  
解析：继承AppCallback.AppCallbackBase，它将会被Dapr运行时调用来调用方法，注册pub/sub主题和注册绑定。

public class BankingService : AppCallback.AppCallbackBase
    {
        ...
    }

**2.支持Dapr的服务调用**  
解析：

public override async Task<InvokeResponse> OnInvoke(InvokeRequest request, ServerCallContext context)
    {
        ...
    }

**3.支持Dapr的pub/sub主题注册**  
解析：

public override Task<ListTopicSubscriptionsResponse> ListTopicSubscriptions(Empty request, ServerCallContext context)
    {
        ...
    }

**4.支持Dapr的pub/sub主题处理**  
解析：

public override async Task<TopicEventResponse> OnTopicEvent(TopicEventRequest request, ServerCallContext context)
    {
        ...
    }

**5.将Dapr部署到K8S环境中**  
解析：查看Dapr控制平面情况：

dapr init -k
    kubectl get po -n dapr-system或者dapr status -k

部署完毕后结果为：

PS C:\Users\ssw> dapr status -k
      NAME                   NAMESPACE    HEALTHY  STATUS   REPLICAS  VERSION  AGE  CREATED
      dapr-placement-server  dapr-system  True     Running  1         1.2.2    3m   2021-07-05 23:28.41
      dapr-operator          dapr-system  False    Running  1         1.2.2    3m   2021-07-05 23:28.41
      dapr-sidecar-injector  dapr-system  True     Running  1         1.2.2    3m   2021-07-05 23:28.41
      dapr-dashboard         dapr-system  True     Running  1         0.6.0    3m   2021-07-05 23:28.41
      dapr-sentry            dapr-system  True     Running  1         1.2.2    3m   2021-07-05 23:28.41

**6.docker build --no-cache**  
解析：当编译镜像的时候并不适用缓存。

**7.docker build --target**  
解析：Set the target build stage to build.

**8.订阅发布API**  
解析：

POST http://localhost:<daprPort>/v1.0/publish/<pubsubname>/<topic>[?<metadata>]
    GET http://localhost:<appPort>/dapr/subscribe

**9.状态管理API**  
解析：

GET http://localhost:<daprPort>/v1.0/state/<storename>/<key>
    POST http://localhost:<daprPort>/v1.0/state/<storename>
    DELETE http://localhost:<daprPort>/v1.0/state/<storename>/<key>

**10.public static class Interlocked**  
解析：提供原子操作对于变量，该变量被多线程共享。

**11.public static int Increment(ref int location)**  
解析：实现一个特定变量，存储结果作为一个原子操作。

**12.OxygenActorStartup**  
解析：自动扫描类型生成对应的actor代理。

**13.ActorStateModel**  
解析：  
\[1\]AutoSave属性：表示否自动持久化，即调用Actor SDK的Statemanage持久化到中间件。  
\[2\]ReminderSeconds属性：表示如果开启持久化，瞬时持久化还是由Actor的Timer按照周期持久化。

**14.maxRequestsPerSecond**  
解析：代表每秒流经该sidecar的请求最大能通过多少前往下游服务。

**15.dapr.io/app-max-concurrency参数**  
解析：同时只能有多个请求被处理。

**16.Dapr限流middleware.http.ratelimit**  
解析：  
\[1\]Dapr限流包含两种模式，一种是客户端限流，一种是服务端限流。  
\[2\]整个限流其实分为下游限流+并发控制两种方式，其实都是为了保护自己/下游服务。

**17.K8S部署zipkin**  
解析：

---
    apiVersion: apps/v1
    kind: Deployment
    metadata:
      name: zipkin
    spec:
      selector:
        matchLabels:
          app: zipkin
      replicas: 1
      template:
        metadata:
          labels:
            app: zipkin
        spec:
          containers:
            - name: zipkin
              image: openzipkin/zipkin:latest
              imagePullPolicy: IfNotPresent
              ports:
                - containerPort: 9411
              env:
                - name: TZ
                  value: "Asia/Shanghai"
    ---
    apiVersion: v1
    kind: Service
    metadata:
      name: zipkin
    spec:
      type: NodePort
      selector:
        app: zipkin
      ports:
        - protocol: TCP
          port: 9411
          targetPort: 9411

**18.samplingRate**  
解析：采样率。

**19.Dapr支持两种Oauth2授权**  
解析：  
\[1\]一种是用户认证模式  
\[2\]一种是客户端凭据模式

**20.middleware.http.oauth2**  
解析：

apiVersion: dapr.io/v1alpha1
    kind: Component
    metadata:
      name: githubauth
      namespace: dapreshop
    spec:
      type: middleware.http.oauth2
      version: v1
      metadata:
      - name: clientId
        value: "your client id"
      - name: clientSecret
        value: "your client secret"
      - name: scopes
        value: "user:email"
      - name: authURL
        value: "https://github.com/login/oauth/authorize"
      - name: tokenURL
        value: "https://github.com/login/oauth/access_token"
      - name: redirectURL
        value: ""
      - name: authHeaderName
        value: "myauth"

**21.ActorHost**  
解析：由运行时提供，包含了允许该actor实例与运行时通信的所有状态。

**22.使用Dapr CLI**  
解析：

dapr run --app-id <app-id> --app-port <port> --components-path <components-path> -- dotnet run -p <project> --urls http://localhost:<port>

**23.AddDapr和AddActors设置**  
解析：

services.AddDapr(options =>
    {
        options.JsonSerializerOptions = new JsonSerializerOptions()
        {
            // Configure custom JSON settings that apply to ALL dapr features.
        };
    })
    .AddActors(options =>
    {
        // Configure actor types here
        options.Actors.RegisterActor<MyActorType>();
    });

**24.public class ActorId**  
解析：在名字空间Dapr.Actors中，ActorId表示在一个actor服务中的actor标识符。

**25.public interface IActorProxyFactory**  
解析：定义接口包括方法来创建actor代理工厂类。

参考文献：  
\[1\]Dapr .NET Core examples：https://github.com/dapr/dotnet-sdk/tree/master/examples  
\[2\]Newbe.Claptrap：https://claptrap.newbe.pro/zh-Hans/