spring-cloud-data-flow-demo

1、将本地包导入mvn仓库 mvn install:install-file -Dfile=C:\spring-cloud-data-flow-source-0.0.1-SNAPSHOT.jar -DgroupId=com.johnguo -DartifactId=spring-cloud-data-flow-source -Dversion=0.0.1-SNAPSHOT -Dpackaging=jar mvn install:install-file -Dfile=C:\spring-cloud-data-flow-processor-0.0.1-SNAPSHOT.jar -DgroupId=com.johnguo -DartifactId=spring-cloud-data-flow-processor-Dversion=0.0.1-SNAPSHOT -Dpackaging=jar mvn install:install-file -Dfile=C:\spring-cloud-data-flow-sink-0.0.1-SNAPSHOT.jar -DgroupId=com.johnguo -DartifactId=spring-cloud-data-flow-sink -Dversion=0.0.1-SNAPSHOT -Dpackaging=jar 2、注册服务 app register --name http-source --type source --uri maven://com.johnguo:spring-cloud-data-flow-source:jar:0.0.1-SNAPSHOT app register --name transform-processor --type processor --uri maven://com.johnguo:spring-cloud-data-flow-processor:jar:0.0.1-SNAPSHOT app register --name logging-sink --type sink --uri maven://com.johnguo:spring-cloud-data-flow-sink:jar:0.0.1-SNAPSHOT 3、创建流 stream create --name transform --definition 'http-source --server.port=8000 | transform-processor --expression=payload.toUpperCase() | logging-sink' 4、启动流 stream deploy --name transform 5、发送测试数据 192.168.2.201:8000/send/hello world