blocks|key|4567516|text|TooTallNate有一个简单的客户端https://github.com/TooTallNate/Java-WebSocket|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4567517|只需将dist文件夹中的java_websocket.jar添加到您的项目中。|4567518|+import+org.java_websocket.client.WebSocketClient;
+import+org.java_websocket.drafts.Draft_10;
+import+org.java_websocket.handshake.ServerHandshake;
+import+org.json.JSONException;
+import+org.json.JSONObject;

++WebSocketClient+mWs+=+new+WebSocketClient(+new+URI(+"ws://socket.example.com:1234"+),+new+Draft_10()+)
{
++++++++++++++++++++@Override
++++++++++++++++++++public+void+onMessage(+String+message+)+{
+++++++++++++++++++++JSONObject+obj+=+new+JSONObject(message);
+++++++++++++++++++++String+channel+=+obj.getString("channel");
++++++++++++++++++++}

++++++++++++++++++++@Override
++++++++++++++++++++public+void+onOpen(+ServerHandshake+handshake+)+{
++++++++++++++++++++++++System.out.println(+"opened+connection"+);
++++++++++++++++++++}

++++++++++++++++++++@Override
++++++++++++++++++++public+void+onClose(+int+code,+String+reason,+boolean+remote+)+{
++++++++++++++++++++++++System.out.println(+"closed+connection"+);
++++++++++++++++++++}

++++++++++++++++++++@Override
++++++++++++++++++++public+void+onError(+Exception+ex+)+{
++++++++++++++++++++++++ex.printStackTrace();
++++++++++++++++++++}

++++++++++++++++};
+//open+websocket
+mWs.connect();
+JSONObject+obj+=+new+JSONObject();
+obj.put("event",+"addChannel");
+obj.put("channel",+"ok_btccny_ticker");
+String+message+=+obj.toString();
+//send+message
+mWs.send(message);|code-block|syntax|javascript|4567519|//并关闭websocket|4567520|+mWs.close();|4567521|entityMap|0|LINK|mutability|MUTABLE|url|https://github.com/TooTallNate/Java-WebSocket^0|K|19|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|W|8|@]|9|@$A|X|B|Y|1|Z]]|C|$]]|$1|D|3|E|5|6|7|10|8|@]|9|@]|C|$]]|$1|F|3|G|5|H|7|11|8|@]|9|@]|C|$I|J]]|$1|K|3|L|5|6|7|12|8|@]|9|@]|C|$]]|$1|M|3|N|5|H|7|13|8|@]|9|@]|C|$I|J]]|$1|O|3|-4|5|6|7|14|8|@]|9|@]|C|$]]]|P|$Q|$5|R|S|T|C|$U|V]]]]

TooTallNate has a simple client side <a href="https://github.com/TooTallNate/Java-WebSocket" rel="noreferrer">https://github.com/TooTallNate/Java-WebSocket</a>

Just add the java_websocket.jar in the dist folder into your project.

<pre><code> import org.java_websocket.client.WebSocketClient;
 import org.java_websocket.drafts.Draft_10;
 import org.java_websocket.handshake.ServerHandshake;
 import org.json.JSONException;
 import org.json.JSONObject;

 WebSocketClient mWs = new WebSocketClient( new URI( "ws://socket.example.com:1234" ), new Draft_10() )
{
 @Override
 public void onMessage( String message ) {
 JSONObject obj = new JSONObject(message);
 String channel = obj.getString("channel");
 }

 @Override
 public void onOpen( ServerHandshake handshake ) {
 System.out.println( "opened connection" );
 }

 @Override
 public void onClose( int code, String reason, boolean remote ) {
 System.out.println( "closed connection" );
 }

 @Override
 public void onError( Exception ex ) {
 ex.printStackTrace();
 }

 };
 //open websocket
 mWs.connect();
 JSONObject obj = new JSONObject();
 obj.put("event", "addChannel");
 obj.put("channel", "ok_btccny_ticker");
 String message = obj.toString();
 //send message
 mWs.send(message);
</code></pre>

// and to close websocket

<pre><code> mWs.close();
</code></pre>

blocks|key|4567558|text|这里有一个简单的例子..您可以下载并测试它的http://www.pretechsol.com/2014/12/java-ee-websocket-simple-example.html|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|4567559|entityMap|0|LINK|mutability|MUTABLE|url|http://www.pretechsol.com/2014/12/java-ee-websocket-simple-example.html^0|M|1Z|0|0^^$0|@$1|2|3|4|5|6|7|L|8|@]|9|@$A|M|B|N|1|O]]|C|$]]|$1|D|3|-4|5|6|7|P|8|@]|9|@]|C|$]]]|E|$F|$5|G|H|I|C|$J|K]]]]

Here is one simple example.. you can download and test it
<a href="http://www.pretechsol.com/2014/12/java-ee-websocket-simple-example.html" rel="nofollow">http://www.pretechsol.com/2014/12/java-ee-websocket-simple-example.html</a>

blocks|key|61344|text|使用此库org.java_websocket|type|unstyled|depth|inlineStyleRanges|entityRanges|data|61345|首先，您应该在build.gradle中导入该库|61346|repositories+{
+mavenCentral()
+}|code-block|syntax|javascript|61347|然后在依赖项{}中添加实现|61348|implementation+"org.java-websocket:Java-WebSocket:1.3.0"|61349|然后，您可以使用以下代码|61350|在您活动中为Websocketclient声明对象，如下所示|61351|private+WebSocketClient+mWebSocketClient;|61352|然后为回调添加此方法|61353|+private+void+ConnectToWebSocket()+{
URI+uri;
try+{
++++uri+=+new+URI("ws://your+web+socket+url");
}+catch+(URISyntaxException+e)+{
++++e.printStackTrace();
++++return;
}

mWebSocketClient+=+new+WebSocketClient(uri)+{
++++@Override
++++public+void+onOpen(ServerHandshake+serverHandshake)+{
++++++++Log.i("Websocket",+"Opened");
++++++++mWebSocketClient.send("Hello+from+"+%2B+Build.MANUFACTURER+%2B+"+"+%2B+Build.MODEL);
++++}

++++@Override
++++public+void+onMessage(String+s)+{
++++++++final+String+message+=+s;
++++++++runOnUiThread(new+Runnable()+{
++++++++++++@Override
++++++++++++public+void+run()+{
++++++++++++++++TextView+textView+=+(TextView)findViewById(R.id.edittext_chatbox);
++++++++++++++++textView.setText(textView.getText()+%2B+"\n"+%2B+message);
++++++++++++}
++++++++});
++++}

++++@Override
++++public+void+onClose(int+i,+String+s,+boolean+b)+{
++++++++Log.i("Websocket",+"Closed+"+%2B+s);
++++}

++++@Override
++++public+void+onError(Exception+e)+{
++++++++Log.i("Websocket",+"Error+"+%2B+e.getMessage());
++++}
};
mWebSocketClient.connect();|61354|}|61355|entityMap^0|0|0|0|0|0|0|0|0|0|0|0^^$0|@$1|2|3|4|5|6|7|10|8|@]|9|@]|A|$]]|$1|B|3|C|5|6|7|11|8|@]|9|@]|A|$]]|$1|D|3|E|5|F|7|12|8|@]|9|@]|A|$G|H]]|$1|I|3|J|5|6|7|13|8|@]|9|@]|A|$]]|$1|K|3|L|5|F|7|14|8|@]|9|@]|A|$G|H]]|$1|M|3|N|5|6|7|15|8|@]|9|@]|A|$]]|$1|O|3|P|5|6|7|16|8|@]|9|@]|A|$]]|$1|Q|3|R|5|F|7|17|8|@]|9|@]|A|$G|H]]|$1|S|3|T|5|6|7|18|8|@]|9|@]|A|$]]|$1|U|3|V|5|F|7|19|8|@]|9|@]|A|$G|H]]|$1|W|3|X|5|6|7|1A|8|@]|9|@]|A|$]]|$1|Y|3|-4|5|6|7|1B|8|@]|9|@]|A|$]]]|Z|$]]

Use this library org.java_websocket

First thing you should import that library in build.gradle

<pre><code>repositories {
 mavenCentral()
 }
</code></pre>

then add the implementation in dependency{}

<pre><code>implementation "org.java-websocket:Java-WebSocket:1.3.0"
</code></pre>

Then you can use this code

In your activity declare object for Websocketclient like

<pre><code>private WebSocketClient mWebSocketClient;
</code></pre>

then add this method for callback

<pre><code> private void ConnectToWebSocket() {
URI uri;
try {
 uri = new URI("ws://your web socket url");
} catch (URISyntaxException e) {
 e.printStackTrace();
 return;
}

mWebSocketClient = new WebSocketClient(uri) {
 @Override
 public void onOpen(ServerHandshake serverHandshake) {
 Log.i("Websocket", "Opened");
 mWebSocketClient.send("Hello from " + Build.MANUFACTURER + " " + Build.MODEL);
 }

 @Override
 public void onMessage(String s) {
 final String message = s;
 runOnUiThread(new Runnable() {
 @Override
 public void run() {
 TextView textView = (TextView)findViewById(R.id.edittext_chatbox);
 textView.setText(textView.getText() + "\n" + message);
 }
 });
 }

 @Override
 public void onClose(int i, String s, boolean b) {
 Log.i("Websocket", "Closed " + s);
 }

 @Override
 public void onError(Exception e) {
 Log.i("Websocket", "Error " + e.getMessage());
 }
};
mWebSocketClient.connect();
</code></pre>

}

blocks|key|61399|text|我的项目中有Spring4.2，许多SockJS+Stomp实现通常与Spring+Boot实现一起工作得很好。This+implementation+from+Baeldung可以工作(对我来说，不需要从Spring4.2到5)。在使用了他的博客中提到的依赖项后，它仍然给了我ClassNotFoundError。我添加了下面的依赖项来修复它。|type|unstyled|depth|inlineStyleRanges|entityRanges|offset|length|data|61400|<dependency>
++++++++<groupId>org.springframework</groupId>
++++++++<artifactId>spring-core</artifactId>
++++++++<version>4.2.3.RELEASE</version>
++++</dependency>|code-block|syntax|javascript|61401|entityMap|0|LINK|mutability|MUTABLE|url|https://www.baeldung.com/websockets-spring^0|1K|X|0|0|0^^$0|@$1|2|3|4|5|6|7|Q|8|@]|9|@$A|R|B|S|1|T]]|C|$]]|$1|D|3|E|5|F|7|U|8|@]|9|@]|C|$G|H]]|$1|I|3|-4|5|6|7|V|8|@]|9|@]|C|$]]]|J|$K|$5|L|M|N|C|$O|P]]]]

I have Spring 4.2 in my project and many SockJS Stomp implementations usually work well with Spring Boot implementations. <a href="https://www.baeldung.com/websockets-spring" rel="nofollow noreferrer">This implementation from Baeldung</a> worked(for me without changing from Spring 4.2 to 5). After Using the dependencies mentioned in his blog, it still gave me ClassNotFoundError. I added the below dependency to fix it. 

<pre><code>&lt;dependency&gt;
 &lt;groupId&gt;org.springframework&lt;/groupId&gt;
 &lt;artifactId&gt;spring-core&lt;/artifactId&gt;
 &lt;version&gt;4.2.3.RELEASE&lt;/version&gt;
 &lt;/dependency&gt;
</code></pre>

Can someone please provide me very simple example of websocket client using <code>javax.websocket</code>?

I want to connect to websocket (ws://socket.example.com:1234), send message (add channel) and listen to messages. All messages (sent &amp; listened) are in JSON format.

And btw is this library the best for simple websocket communication?

javax.websocket client simple example

Spring Boot

JSON

Java

有没有人可以给我提供一个使用javax.websocket的websocket客户端的简单示例我想连接到websocket (ws://socket.example.com:1234)，发送消息(添加通道)和收听消息。所有消息(已发送和已侦听)均为JSON格式。顺便说一下，对于简单的websocket通信，这个库是最好...

问javax.websocket客户端简单示例
EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问javax.websocket客户端简单示例EN

社区

活动

资源

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问javax.websocket客户端简单示例
EN