搭建教程 https://www.yuque.com/luoqiz/docker/ucwp59
    powejob 框架介绍 https://www.yuque.com/powerjob/guidence/hczm7m

    1.         <powerjob.worker.starter.version>4.0.1</powerjob.worker.starter.version>
    2.         <powerjob.official.processors.version>1.1.0</powerjob.official.processors.version>
    4.         <dependency>
    5.             <groupId>tech.powerjob</groupId>
    6.             <artifactId>powerjob-worker</artifactId>
    7.             <version>${powerjob.worker.starter.version}</version>
    8.         </dependency>
    9.         <dependency>
    10.             <groupId>tech.powerjob</groupId>
    11.             <artifactId>powerjob-official-processors</artifactId>
    12.             <version>${powerjob.official.processors.version}</version>
    13.         </dependency>
    1. powerjob:
    2.   worker:
    3.     server-address: 192.168.3.25:7700
    4.     app-name: pay-local
    5. #    akka-port: 27777
    6.     max-appended-wf-context-length: 16384
    7.     max-result-length: 16384
    8.     store-strategy: disk

    注意事项： 我在开发的时候碰到worker注册的akka地址不正确，究其原因是我安装了zerotier-one，其生成的虚拟网卡被默认使用，所以worker运行时需要指定网卡。指定网卡必须在运行时的jvm参数修改 -Dpowerjob.network.interface.preferred="Realtek PCIe GbE Family Controller" 其它方式不可用。
    image.png

    Linux 查看网卡名称 ifconfig 

    2. [root@pay ~]# ifconfig
    3. docker0: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
    4.         inet 172.17.0.1  netmask 255.255.0.0  broadcast 172.17.255.255
    5.         inet6 fe80::42:3aff:fe01:da7e  prefixlen 64  scopeid 0x20<link>
    6.         ether 02:42:3a:01:da:7e  txqueuelen 0  (Ethernet)
    7.         RX packets 719157  bytes 380835206 (363.1 MiB)
    8.         RX errors 0  dropped 0  overruns 0  frame 0
    9.         TX packets 936651  bytes 292035283 (278.5 MiB)
    10.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    12. ens192: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
    13.         inet 192.168.3.25  netmask 255.255.255.0  broadcast 192.168.3.255
    14.         inet6 fe80::c648:c2fa:aa61:dfa3  prefixlen 64  scopeid 0x20<link>
    15.         ether 00:50:56:8d:35:e5  txqueuelen 1000  (Ethernet)
    16.         RX packets 1853894  bytes 893297825 (851.9 MiB)
    17.         RX errors 0  dropped 1757  overruns 0  frame 0
    18.         TX packets 1396546  bytes 219108395 (208.9 MiB)
    19.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    21. lo: flags=73<UP,LOOPBACK,RUNNING>  mtu 65536
    22.         inet 127.0.0.1  netmask 255.0.0.0
    23.         inet6 ::1  prefixlen 128  scopeid 0x10<host>
    24.         loop  txqueuelen 1000  (Local Loopback)
    25.         RX packets 1301653  bytes 505240697 (481.8 MiB)
    26.         RX errors 0  dropped 0  overruns 0  frame 0
    27.         TX packets 1301653  bytes 505240697 (481.8 MiB)
    28.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    30. veth37bde42: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
    31.         inet6 fe80::4b0:8ff:fe89:dcaf  prefixlen 64  scopeid 0x20<link>
    32.         ether 06:b0:08:89:dc:af  txqueuelen 0  (Ethernet)
    33.         RX packets 6298  bytes 1404783 (1.3 MiB)
    34.         RX errors 0  dropped 0  overruns 0  frame 0
    35.         TX packets 6616  bytes 521062 (508.8 KiB)
    36.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    38. veth899a11c: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
    39.         inet6 fe80::1cf0:52ff:fe02:e32c  prefixlen 64  scopeid 0x20<link>
    40.         ether 1e:f0:52:02:e3:2c  txqueuelen 0  (Ethernet)
    41.         RX packets 315347  bytes 71506015 (68.1 MiB)
    42.         RX errors 0  dropped 0  overruns 0  frame 0
    43.         TX packets 313133  bytes 84401958 (80.4 MiB)
    44.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0
    46. vethc04e18f: flags=4163<UP,BROADCAST,RUNNING,MULTICAST>  mtu 1500
    47.         inet6 fe80::d4a1:8fff:fe62:cbb1  prefixlen 64  scopeid 0x20<link>
    48.         ether d6:a1:8f:62:cb:b1  txqueuelen 0  (Ethernet)
    49.         RX packets 374862  bytes 301742159 (287.7 MiB)
    50.         RX errors 0  dropped 0  overruns 0  frame 0
    51.         TX packets 603035  bytes 202674566 (193.2 MiB)
    52.         TX errors 0  dropped 0 overruns 0  carrier 0  collisions 0

    image.png
    windows获取网卡名称命令 ipconfig /all 

    1. C:\Users\EDZ>ipconfig /all
    3. Windows IP 配置
    5.    主机名  . . . . . . . . . . . . . : WINDOWS-Q1CF71D
    6.    主 DNS 后缀 . . . . . . . . . . . :
    7.    节点类型  . . . . . . . . . . . . : 混合
    8.    IP 路由已启用 . . . . . . . . . . : 否
    9.    WINS 代理已启用 . . . . . . . . . : 否
    11. 以太网适配器 以太网:
    13.    连接特定的 DNS 后缀 . . . . . . . :
    14.    描述. . . . . . . . . . . . . . . : Realtek PCIe GbE Family Controller
    15.    物理地址. . . . . . . . . . . . . : A8-A1-59-05-59-9B
    16.    DHCP 已启用 . . . . . . . . . . . : 是
    17.    自动配置已启用. . . . . . . . . . : 是
    18.    本地链接 IPv6 地址. . . . . . . . : fe80::5d51:6336:68c1:2b2d%4(首选)
    19.    IPv4 地址 . . . . . . . . . . . . : 192.168.10.44(首选)
    20.    子网掩码  . . . . . . . . . . . . : 255.255.254.0
    21.    获得租约的时间  . . . . . . . . . : 2021年4月25日 16:46:23
    22.    租约过期的时间  . . . . . . . . . : 2021年4月26日 0:46:23
    23.    默认网关. . . . . . . . . . . . . : 192.168.10.1
    24.    DHCP 服务器 . . . . . . . . . . . : 192.168.10.1
    25.    DHCPv6 IAID . . . . . . . . . . . : 329818457
    26.    DHCPv6 客户端 DUID  . . . . . . . : 00-01-00-01-25-57-5A-F2-A8-A1-59-05-59-9B
    27.    DNS 服务器  . . . . . . . . . . . : 10.1.1.1
    28.                                        119.29.29.29
    29.    TCPIP 上的 NetBIOS  . . . . . . . : 已启用
    31. 以太网适配器 VMware Network Adapter VMnet1:
    33.    连接特定的 DNS 后缀 . . . . . . . :
    34.    描述. . . . . . . . . . . . . . . : VMware Virtual Ethernet Adapter for VMnet1
    35.    物理地址. . . . . . . . . . . . . : 00-50-56-C0-00-01
    36.    DHCP 已启用 . . . . . . . . . . . : 否
    37.    自动配置已启用. . . . . . . . . . : 是
    38.    本地链接 IPv6 地址. . . . . . . . : fe80::1930:ae0e:fc9:7663%6(首选)
    39.    IPv4 地址 . . . . . . . . . . . . : 192.168.247.1(首选)
    40.    子网掩码  . . . . . . . . . . . . : 255.255.255.0
    41.    默认网关. . . . . . . . . . . . . :
    42.    DHCPv6 IAID . . . . . . . . . . . : 134238294
    43.    DHCPv6 客户端 DUID  . . . . . . . : 00-01-00-01-25-57-5A-F2-A8-A1-59-05-59-9B
    44.    DNS 服务器  . . . . . . . . . . . : fec0:0:0:ffff::1%1
    45.                                        fec0:0:0:ffff::2%1
    46.                                        fec0:0:0:ffff::3%1
    47.    TCPIP 上的 NetBIOS  . . . . . . . : 已启用
    49. 以太网适配器 VMware Network Adapter VMnet8:
    51.    连接特定的 DNS 后缀 . . . . . . . :
    52.    描述. . . . . . . . . . . . . . . : VMware Virtual Ethernet Adapter for VMnet8
    53.    物理地址. . . . . . . . . . . . . : 00-50-56-C0-00-08
    54.    DHCP 已启用 . . . . . . . . . . . : 否
    55.    自动配置已启用. . . . . . . . . . : 是
    56.    本地链接 IPv6 地址. . . . . . . . : fe80::3496:5380:5cb2:2e6f%8(首选)
    57.    IPv4 地址 . . . . . . . . . . . . : 192.168.153.1(首选)
    58.    子网掩码  . . . . . . . . . . . . : 255.255.255.0
    59.    默认网关. . . . . . . . . . . . . :
    60.    DHCPv6 IAID . . . . . . . . . . . : 268456022
    61.    DHCPv6 客户端 DUID  . . . . . . . : 00-01-00-01-25-57-5A-F2-A8-A1-59-05-59-9B
    62.    DNS 服务器  . . . . . . . . . . . : fec0:0:0:ffff::1%1
    63.                                        fec0:0:0:ffff::2%1
    64.                                        fec0:0:0:ffff::3%1
    65.    TCPIP 上的 NetBIOS  . . . . . . . : 已启用
    67. 以太网适配器 ZeroTier One [83048a063288b166]:
    69.    连接特定的 DNS 后缀 . . . . . . . :
    70.    描述. . . . . . . . . . . . . . . : ZeroTier Virtual Port
    71.    物理地址. . . . . . . . . . . . . : 66-84-E3-C2-71-A5
    72.    DHCP 已启用 . . . . . . . . . . . : 否
    73.    自动配置已启用. . . . . . . . . . : 是
    74.    本地链接 IPv6 地址. . . . . . . . : fe80::bdb7:929e:60d:16d6%9(首选)
    75.    IPv4 地址 . . . . . . . . . . . . : 10.244.187.3(首选)
    76.    子网掩码  . . . . . . . . . . . . : 255.255.0.0
    77.    默认网关. . . . . . . . . . . . . : 25.255.255.254
    78.    DHCPv6 IAID . . . . . . . . . . . : 342263011
    79.    DHCPv6 客户端 DUID  . . . . . . . : 00-01-00-01-25-57-5A-F2-A8-A1-59-05-59-9B
    80.    DNS 服务器  . . . . . . . . . . . : fec0:0:0:ffff::1%1
    81.                                        fec0:0:0:ffff::2%1
    82.                                        fec0:0:0:ffff::3%1
    83.    TCPIP 上的 NetBIOS  . . . . . . . : 已启用

    image.png
    编写案例

    1. // 支持 SpringBean 的形式
    2. @Component
    3. public class BasicProcessorDemo implements BasicProcessor {
    5.     @Resource
    6.     private MysteryService mysteryService;
    8.     @Override
    9.     public ProcessResult process(TaskContext context) throws Exception {
    11.         // 在线日志功能，可以直接在控制台查看任务日志，非常便捷
    12.         OmsLogger omsLogger = context.getOmsLogger();
    13.         omsLogger.info("BasicProcessorDemo start to process, current JobParams is {}.", context.getJobParams());
    15.         // TaskContext为任务的上下文信息，包含了在控制台录入的任务元数据，常用字段为
    16.         // jobParams（任务参数，在控制台录入），instanceParams（任务实例参数，通过 OpenAPI 触发的任务实例才可能存在该参数）
    18.         // 进行实际处理...
    19.         mysteryService.hasaki();
    21.         // 返回结果，该结果会被持久化到数据库，在前端页面直接查看，极为方便
    22.         return new ProcessResult(true, "result is xxx");
    23.     }
    24. }

    此时启动后查看web控制台
    image.png

    image.png

    此时查看控制台打印，应该是没有问题的，也可以web查看日志
    image.png