Client Client public void sendobject(object message) String String Web Container String RemoteEndpoint String Endpoint throwsioexception, EncodeExcept

Size: px

Start display at page:

Download "Client Client public void sendobject(object message) String String Web Container String RemoteEndpoint String Endpoint throwsioexception, EncodeExcept"

うきえやまがた
7 years ago
Views:

1 @OnMessage public void handlecounter(int newvalue) public void handleboolean(boolean b) {... public void sendobject(object message) throws IOException, EncodeException

2 Client Client public void sendobject(object message) String String Web Container String RemoteEndpoint String Endpoint throwsioexception, EncodeException public String encode(foo foo) throws EncodeException String FooDecoder Foo String FooEncoder Foo RemoteEndpoint Endpoint

3 @OnMessage public void handlemessageasstream( InputStream messagestream, Session session) { // read from the messagestream // until you have consumed the // whole binary public void handlemessageinchunks( String chunk, boolean islast) { // reconstitute the message // from the chunks as they arrive public Writer getsendwriter() throws IOException public OutputStream getsendstream() throws IOException

4 public void sendtext( String partialtextmessage, boolean islast) throws IOException public Future<Void> sendtext( String textmessage) public void sentbinary( ByteBuffer partialbinarymessage, boolean islast) throws IOException public void sendtext( String textmessage, SendHandler handler)

5 <ws or wss>://<hostname>:<port>/ <web-app-context-path>/<websocket-path>? <query-string> /airlines/{service-class /airlines/coach /airlines/first /airlines/business public class MyBookingNotifier public void initializeupdates(session String sclass) { if {"first".equals(sclass)) { // open champagne else if ("business".equals(sc1ass)) { // heated nuts else { // don't bang your head on our aircraft...

6 @ServerEndpoint("/travel/hotels/{stars") public class HotelBookingService { public void handleconnection{ Session s, EndpointConfig config) { String mypath = ((ServerEndpointConfig) config).getpath(); // mypath is "/travel/hotels/{stars"... Session.getRequestURI() ws://fun.org/customer/services/ travel/hotels/3 /customer/services/travel/hotels/3 <ws or wss>://<host:name>:<port:>/ <web-app-context-path>/<websocket-path>? <query-string> <form name="input" action="form-processor" method="get"> Your Username: <input type="text" name="user"> <input type="submit" value="submit"> </form>

7 /form-processor?user=jared public String getquerystring() public Map<String,List<String>> getrequest:parametermap() ws://fun.org/customer/ services/travel/hotels/4? showpics=thumbnails& public class HotelBookingService2 { public void handleconnection( Session session, EndpointConfig config) { String picturetype = session.getrequestparametermap().get("showpics").get(0); String textmode = session.getrequestparametermap().get("description").get(0);......

9 import java.util.arraylist; import java.util.list; import javax.websocket.*; public class Transcript { private List<String> messages = new ArrayList<>(); private List<String> usernames = new ArrayList<>(); private int maxlines; private static String TRANSCRIPT_ATTRIBUTE_NAME = "CHAT_TRANSCRIPT_AN"; public static Transcript gettranscript(endpointconfig ec) { if (!ec.getuserproperties(). containskey(transcript_attribute_name)) { ec.getuserproperties().put(transcript_attribute_name, new Transcript(20)); return (Transcript) c.getuserproperties().get(transcript_attribute_name); Transcript(int maxlines) { this.maxlines = maxlines; public String getlastusername() { return usernames.get(usernames.size() -1); public String getlastmessage() { return messages.get(messages.size() -1);

10 public void addentry( string username, String message) { if (usernames.size() > maxlines) { usernames.remove(0); messages.remove(0); usernames.add(username); messages.add(message); private void broadcasttranscriptupdate() { for (Session nextsession : session.getopensessions()) { ChatUpdateMessage cdm = new ChatUpdateMessage( this.transcript.getlastusername(), this.transcript.getlastmessage()); try{ nextsession.getbasicremote(.sendobject(cdm; catch (IOException EncodeException ex) { System.out.println( "Error updating a client : " + ex.getmessage());

11 import java.util.iterator; import javax.websocket.encodeexception; import javax.websocket.encoder; import javax.websocket.endpointconfig; public class ChatEncoder implements Encoder.Text<ChatMessage> { public static final String SEPARATOR = public void init(endpointconfig config) public void destroy() public String encode(chatmessage cm) throws EncodeException { if (cm instanceof StructuredMessage) { String datastring = ""; for (Iterator itr = ((StructuredMessage) cm).getlist().iterator(); itr.hasnext(); ) { datastring = datastring + SEPARATDR + itr.next(); return cm.gettype() + datastring; else if (cm instanceof BasicMessage) { return cm.gettype() + ((BasicMessage) cm).getdata(); else { throw new EncodeException(cm, "Cannot encode messages of type: " + cm.getc1ass());

//web apps / ノテーションを付加したendChatChannel()メソッドが別れの挨拶なしでチャットルームから退室したユーザーがいることを通知するメッセージをすべての接続クライアントにブロードキャストします

WebSocketプロトコルの基本的な概念とサーバーからのプッシュを必要とする状況について考察し Java WebSocket エンドポイントのライフサイクル Java WebSocket APIの主なクラス

その中にあるエンドポイントにクライアントリクエストをマッチングする方法についても学習しました最後に多数のJava WebSocket API機能を使用するチャットアプリケーションについて考察しました今回学んだ知識を使うことで

Danny Coward Liquid Robotics のプリンシパルソフトウェアエンジニア以前はオラクルおよびその前のSun Microsystems でJava開発チームに属し特にWebSocketに関する業務に従事した

12 //web apps / ノテーションを付加したendChatChannel()メソッドが別れの挨拶なしでチャットルームから退室したユーザーがいることを通知するメッセージをすべての接続クライアントにブロードキャストしますチャット画面のスクリーンショットを見返すと JessとRobではチャットルームからの退室の仕方に違いがあることを確認できますまとめ 2回に分けてお届けした本記事では Java WebSocketエンドポイントの作成方法を学習しました WebSocketプロトコルの基本的な概念とサーバーからのプッシュを必要とする状況について考察し Java WebSocket エンドポイントのライフサイクル Java WebSocket APIの主なクラスエンコード処理およびデコード処理の手法を確認しましたまた Java WebSocket APIでサポートされる各種のメッセージングモードに注目しましたサーバーエンドポイントをWebアプリケーションのURI空間にマップする方法とその中にあるエンドポイントにクライアントリクエストをマッチングする方法についても学習しました最後に多数のJava WebSocket API機能を使用するチャットアプリケーションについて考察しました今回学んだ知識を使うことで長期存続型コネクションを使用したアプリケーションを簡単に構築できます </article> 本記事は書籍 Java EE 7: The Big Picture の内容を発行者のOracle Pressの許可を得て改訂したものです Danny Coward Liquid Robotics のプリンシパルソフトウェアエンジニア以前はオラクルおよびその前のSun Microsystems でJava開発チームに属し特にWebSocketに関する業務に従事した learn more オラクルのJava WebSocketチュートリアル Long polling, a WebSocket alternative 34 ORACLE.COM/JAVAMAGAZINE ///////////////////// JANUARY/FEBRUARY 2016

Java (9) 1 Lesson Java System.out.println() 1 Java API 1 Java Java 1

Java (9) 1 Lesson Java System.out.println() 1 Java API 1 Java Java 1 Java (9) 1 Lesson 7 2008-05-20 Java System.out.println() 1 Java API 1 Java Java 1 GUI 2 Java 3 1.1 5 3 1.0 10.0, 1.0, 0.5 5.0, 3.0, 0.3 4.0, 1.0, 0.6 1 2 4 3, ( 2 3 2 1.2 Java (stream) 4 1 a 5 (End of