worker 注册 workflow 和 activity
然后分别 轮询 workflow 和 activity taskqueue 执行

两个 worker 实例
work1 一个 只有 1个 activity 
work2 一个 有 2个 activity
模拟 生产环境 升级更新 ，代码实现不一致的问题

运行工作流  会得到 3种结果
1个 activity 时的结果
2个 activity 时的结果
错误结果  ， 第二个activity 被 work1 取走执行， 报错，因为他根本没有 注册第二个activty

EVENT_TYPE_WORKFLOW_EXECUTION_FAILED
Activity Type  "echo2" is not registered with a worker. Known types are: echo"



注意查看工作流历史事件信息
identity 为具体的执行者

event_id: 13
event_time {
  seconds: 1650952955
  nanos: 778616000
}
event_type: EVENT_TYPE_ACTIVITY_TASK_FAILED
task_id: 25166370
activity_task_failed_event_attributes {
  failure {
    message: "Activity Type \"echo2\" is not registered with a worker. Known types are: echo"
    source: "JavaSDK"
    stack_trace: "
io.temporal.internal.sync.POJOActivityTaskHandler.handle(POJOActivityTaskHandler.java:199)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:193)
io.temporal.internal.worker.ActivityWorker$TaskHandlerImpl.handle(ActivityWorker.java:151)
io.temporal.internal.worker.PollTaskExecutor.lambda$process$0(PollTaskExecutor.java:73)
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
java.lang.Thread.run(Thread.java:748)"

    application_failure_info {
      type: "java.lang.IllegalArgumentException"
    }
  }
  scheduled_event_id: 11
  started_event_id: 12
  identity: "12666@dugang"
  retry_state: RETRY_STATE_MAXIMUM_ATTEMPTS_REACHED
}





可以开启 LocalActivity , activity就不会调度到别的机器上




private final EchoActivities activities = Workflow.newActivityStub(EchoActivities.class,
  // 超时设置
  ActivityOptions.newBuilder().setStartToCloseTimeout(Duration.ofSeconds(TIMEOUT_SECONDS))
  // 设置最大重试次数 ，否则会重试直到最大次数
  .setRetryOptions(RetryOptions.newBuilder().setMaximumAttempts(1).build()).build());
		
		
// LocalActivity , 避免被调度到其他机器上 (被别的worker 拉取到) ，可提升性能	

private final EchoActivities activities = Workflow.newLocalActivityStub(EchoActivities.class,
  // 超时设置
  LocalActivityOptions.newBuilder().setStartToCloseTimeout(Duration.ofSeconds(TIMEOUT_SECONDS))
  // 设置最大重试次数 ，否则会重试直到最大次数
  .setRetryOptions(RetryOptions.newBuilder().setMaximumAttempts(1).build()).build());

	

工作流历史事件从 17个变为10个	





基本可以断定 
数据库 和 temporal-server 不会存 工作流注册信息的
一个worker注册的工作流信息  ，只有他自己知道
任务的路由匹配机制  只基于 名字和 taskqueue ,  跟 注册的工作流信息无关



com.dyyx.temporal.demo.echo.EchoWorker
com.dyyx.temporal.demo.echo.EchoWorkerOneActivity


完整代码
https://gitee.com/dyyx/hellocode/tree/master/demo/temporal/sdkdemo