本文介绍: 【代码】java websocket客户端。
<dependency>
<groupId>org.java-websocket</groupId>
<artifactId>Java-WebSocket</artifactId>
<version>1.5.3</version>
</dependency>
package batteryplatform;
import java.net.URI;
import java.net.URISyntaxException;
import org.java_websocket.client.WebSocketClient;
import org.java_websocket.enums.ReadyState;
import org.java_websocket.handshake.ServerHandshake;
public class WebsocketClientTest {
public static void main(String[] args) throws Exception {
URI uri = new URI("ws://localhost:8080/websocket/bigscreen3");
WebSocketClient c = new WebSocketClient(uri) {
@Override
public void onOpen(ServerHandshake handshakedata) {
// TODO Auto-generated method stub
}
@Override
public void onMessage(String message) {
System.err.println(message);
}
@Override
public void onClose(int code, String reason, boolean remote) {
// TODO Auto-generated method stub
}
@Override
public void onError(Exception ex) {
// TODO Auto-generated method stub
}
};
while(true) {
try{
if(c.getReadyState()!= ReadyState.OPEN) {
if(c.getReadyState()== ReadyState.NOT_YET_CONNECTED) {
if(c.isClosed()) {
System.err.println("连接关闭,正在重新连接中……");
c.reconnect();
}else{
System.err.println("建立连接中……");
c.connect();
}
}else if( c.getReadyState() == ReadyState.CLOSED){
System.err.println("连接关闭,正在重新连接中……");
c.reconnect();
}
}
}catch(Exception e) {
System.err.println("连接异常,正在重新连接中……");
c.reconnect();
e.printStackTrace();
}
Thread.sleep(1000);
}
}
}
原文地址:https://blog.csdn.net/oThrowsException/article/details/135955006
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若转载,请注明出处:http://www.7code.cn/show_66177.html
如若内容造成侵权/违法违规/事实不符,请联系代码007邮箱:suwngjj01@126.com进行投诉反馈,一经查实,立即删除!
声明:本站所有文章,如无特殊说明或标注,均为本站原创发布。任何个人或组织,在未征得本站同意时,禁止复制、盗用、采集、发布本站内容到任何网站、书籍等各类媒体平台。如若本站内容侵犯了原著者的合法权益,可联系我们进行处理。