java socket调用接口_java调用websocket接口
項目中需要調用第三方語音電話接口,代碼如下:
1.pom.xml引入websocket依賴
org.java-websocket
Java-WebSocket
1.3.8
2.YiWeiDialUtil.java
package com.yudu.sms.util;
import com.alibaba.fastjson.JSONObject;
import org.java_websocket.WebSocket;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.handshake.ServerHandshake;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.net.URI;
import java.net.URISyntaxException;
public class YiWeiDialUtil {
private static final Logger logger = LoggerFactory.getLogger(YiWeiDialUtil.class);
public static void dial(String ws, String phone, String recordName) {
try {
URI uri = new URI(ws);
WebSocketClient client = new WebSocketClient(uri) {
@Override
public void onOpen(ServerHandshake serverHandshake) { }
@Override
public void onMessage(String s) {
logger.info("返回的數據:" + s);
JSONObject jo = JSONObject.parseObject(s);
String dynamicdata = jo.getString("dynamicdata");
if (dynamicdata != null) {
JSONObject jo_dynamicdata = JSONObject.parseObject(dynamicdata);
String realtimestate = jo_dynamicdata.getString("realtimestate");
if (realtimestate.equals("outconnected")) {
send("{\"command\":\"closeheadsettochannel\"}");
String recordMp3 = System.getProperty("user.dir") + "\\src\\main\\resources\\" + recordName + ".mp3";
String record = "{\"command\":\"PlayStartRecord\",\"arguments\":{\"content\":\"" + recordMp3 + "\"}}";
send(record);
}
}
}
@Override
public void onClose(int i, String s, boolean b) { }
@Override
public void onError(Exception e) {
logger.error(e.getMessage());
}
};
//建立連接
client.connect();
while (!client.getReadyState().equals(WebSocket.READYSTATE.OPEN)) {
logger.info("連接中...");
}
String dial = "{\"command\":\"Dial\",\"arguments\":{\"phone\":\"" + phone + "\"}}";
client.send(dial);
} catch (URISyntaxException e) {
logger.info(e.getMessage());
}
}
}
···
總結
以上是生活随笔為你收集整理的java socket调用接口_java调用websocket接口的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: java8 foreach 异常_错误处
- 下一篇: linux查看分区树形状态,查看Linu