添加http adapter相關(guān)的jar包依賴(lài)

• 上傳http adapter 依賴(lài)的jar

mkdir lib-io
cp httpcore-4.0.1.jar lib-io/
cp httpcore-nio-4.0.1.jar lib-io/
cp httpclient-4.0.1.jar lib-io/

• 修改bin/setclasspath.sh

## 添加如下依賴(lài)
LIB_IO=$BASEDIR/lib-io
# Esper io
#
CLASSPATH=$CLASSPATH:$LIB/esperio-http-6.0.1.jar
CLASSPATH=$CLASSPATH:$LIB_IO/httpcore-4.0.1.jar
CLASSPATH=$CLASSPATH:$LIB_IO/httpclient-4.0.1.jar
CLASSPATH=$CLASSPATH:$LIB_IO/httpcore-nio-4.0.1.jar
##可以試下
##CLASSPATH=$CLASSPATH:$LIB_IO/*

部署epl(2選1)

直接部署epl

• vim echo.epl

module cn.wanda.tech.esper.quickstart;

@Name('Request')
create schema Request(uuid string,msg string);

@Name('Response')
create schema Response(uuid string,msg string);

@Name('Process')
On Request insert into Response select *;

@Name('Display')
select * from Response

• 部署

cp echo.epl hotdeploy/

• 確認(rèn)
  • 通過(guò)http://127.0.0.1:8400/esperhqapp/ ->Browse Deployments 確認(rèn)加載成功

通過(guò)war包部署(方便統(tǒng)一管理依賴(lài)的各種udf等)

• 構(gòu)建項(xiàng)目

git clone https://git.oschina.net/wangpeibin/esper-job.git

• 導(dǎo)入esper-job-quickstart
• 添加需要使用的java class和方法
• 生成war包

mvn package

• 部署

cp target/xxxxx.war hotdeploy/

• 確認(rèn)
  • 同上

配置輸出

• 配置conf/esper-default.xml

<plugin-loader name="EsperIOHTTPAdapter" class-name="com.espertech.esperio.http.EsperIOHTTPAdapterPlugin">
  <config-xml>
    <esperio-http-configuration>
      <!-- 輸入 -->
      <service name="myservice" port="8079" nio="true"/>
      <get service="myservice" pattern="*"/>
      <!-- 輸出 -->
      <request stream="Response" uri="http://127.0.0.1:8080/callback"/>
    </esperio-http-configuration>
  </config-xml>
</plugin-loader>

• 重啟服務(wù)

sh bin/esperee.sh stop
# 可能需要等一陣 等待完全退出
sh bin/esperee.sh start

接受http adapter的輸出

• 使用spring boot 快速搭建服務(wù)
• 添加 controller

@Controller
public class EventController {
    private static Logger log = LoggerFactory.getLogger(EventController.class);
    
    @ResponseBody
    @RequestMapping(value = "/callback", method = RequestMethod.GET)
    public void callback(HttpServletRequest request) {
        log.info("callback {} {}", request.getRequestURI(), request.getQueryString());
    }
}

• 啟動(dòng)spring boot 服務(wù)

mvn spring-boot:run

往http adapter 發(fā)送請(qǐng)求

wget http://127.0.0.1:8079/sendevent?stream=Request&msg=Joe

驗(yàn)證結(jié)果

• spring boot服務(wù)有相應(yīng)的log輸出