shopex Prism sdk (java version)

用途

功能

要求

构建安装

使用maven构建

git clone https://github.com/hashio/websocket-client.git
cd websocket-client
mvn clean install

git clone https://github.com/ShopEx/prism-java.git
cd prism-java
mvn clean install

<dependency>
 <groupId>cn.shopex</groupId>
 <artifactId>prism-sdk</artifactId>
 <version>1.0</version>
</dependency>

用法

String url = "http://dilbmtcv.apihub.cn/api";
String key = "buwb2lii";
String secret = "ucr72ygfutspqeuu6s36";
Boolean https_model = true;#可选
PrismClient prismClient = new PrismClient(url,key,secret);
或者
PrismClient prismClient = new PrismClient(url,key,secret,https_model);

//api请求PATH路径
String methodPath = "/platform/notify/write";
Map<String,String> appParams = new HashMap<String, String>();
//添加API请求所需的应用级参数
appParams.put("data","hello world");
//发送POST请求
String apiResult = prismClient.doPost(methodPath, appParams);
System.out.println(apiResult);

//api请求PATH路径
String methodPath = "/platform/notify/status";
Map<String,String> appParams = new HashMap<String, String>();
//发送GET请求
String apiResult = prismClient.doGet(methodPath,appParams);
System.out.println(apiResult);

设置WebSocket生命周期函数

prismClient.setPrismMsgHandler(new PrismMsgHandler() {
 //Websocket连接完成时触发调用
 @Override
 public void onOpen(WebSocket socket) {
 System.out.println("---> open");
 }
 //接受到Websocket服务端信息时触发调用
 @Override
 public void onMessage(WebSocket socket, PrismMsg prismMsg) {
 System.out.println("---> receive msg:"+prismMsg);
 if (prismMsg.getTag() == 1) {//这里只对第一条消息做ACK应答
 try {
 socket.send(prismClient.assembleAckData(prismMsg.getTag()));
 System.out.println("发送ACK完成:"+prismMsg.getTag());
 } catch (WebSocketException e) {
 e.printStackTrace();
 }
 }
 }
 //Websocket发生异常时触发调用
 @Override
 public void onError(WebSocket socket, WebSocketException e) {
 e.printStackTrace();
 System.out.println("---> error:"+e);
 }
 //Websocket连接关闭时触发调用
 @Override
 public void onClose(WebSocket socket) {
 System.out.println("---> close");
 }
});

建立websocket连接

prismClient.executeNotify();

发布消息

prismClient.publish("order.new","hello world");

开启队列消费

prismClient.consume();

应答消息

prismClient.ack(1);

prismClient.requireOauth(request,response);//启动oauth认证

@Controller
@RequestMapping("/user")
public class LoginController {
 @Resource
 private PrismClient prismClient;
 //测试oauth授权
 @RequestMapping("/login")
 public ModelAndView login(HttpServletRequest request,HttpServletResponse response) {
 ModelAndView view = new ModelAndView("/index");
 prismClient.requireOauth(request,response);
 return view;
 }
}