2

プラットフォームのステータスによると、そうあるべきです。基本的な Hello World の概念実証を実行しようとしていますが、Java クライアントを PlayN でサーバーに接続できません。createWebSocket() を呼び出すとすぐに、onClose() が呼び出されます。ただし、標準の html ページを使用してサーバーに接続できました。

クライアントコード:

    WebSocket s = PlayN.net().createWebSocket("ws://localhost:8080/test", new Net.WebSocket.Listener(){
    public void   onClose() {System.out.println("close");};       
    public void   onDataMessage(ByteBuffer msg) {System.out.println("data");};
    public void   onError(String reason) {System.out.println("error");};
    public void   onOpen() {System.out.println("open");};
    public void   onTextMessage(String msg) { System.out.println("text");};
    });
4

2 に答える 2

1

私はついに問題を見つけました。PlayN のバージョン 1.4 は Draft10 dy デフォルトを使用します。PlayN のローカル コピーを使用するように更新しました。

于 2012-10-29T14:12:40.460 に答える
1

Jetty での WebSocket サーブレットの実装例を次に示します。

import java.io.IOException;
import java.util.Set;
import java.util.concurrent.CopyOnWriteArraySet;

import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import org.eclipse.jetty.websocket.WebSocket;
import org.eclipse.jetty.websocket.WebSocketFactory;

public class SampleServlet extends HttpServlet {
    private static final long           serialVersionUID    = 1L;

    private WebSocketFactory            wsFactory;
    private final Set<SampleWebSocket>  members             = new CopyOnWriteArraySet<SampleWebSocket>();

    @Override
    public void init() throws ServletException {
        wsFactory = new WebSocketFactory( new WebSocketFactory.Acceptor() {

            @Override
            public boolean checkOrigin( final HttpServletRequest request, final String origin ) {
                // Allow all origins
                return true;
            }

            @Override
            public WebSocket doWebSocketConnect( final HttpServletRequest request, final String protocol ) {
                return new SampleWebSocket();
            }

        } );
        wsFactory.setBufferSize( 4096 );
        wsFactory.setMaxIdleTime( 60000 );
    }

    @Override
    protected void doGet( final HttpServletRequest request, final HttpServletResponse response ) throws IOException {
        if ( wsFactory.acceptWebSocket( request, response ) ) {
            return;
        }

        response.sendError( HttpServletResponse.SC_SERVICE_UNAVAILABLE, "Websocket only" );
    }

    public class SampleWebSocket implements WebSocket.OnTextMessage {
        private volatile Connection         connection;

        public SampleWebSocket(  ) {
        }

        @Override
        public void onClose( final int closeCode, final String message ) {
            members.remove( this );
            System.out.println( "onClose: closeCode=" +closeCode+ ", message: '" +message+ "'" );       
        }

        @Override
        public void onOpen( final Connection connection ) {
            this.connection = connection;
            System.out.println( "onOpen: connection=" +connection );        
            members.add( this );

            // Send sample binary message back
            try {
                connection.sendMessage( "Sample message" );
            } catch ( final IOException e ) {
                e.printStackTrace();
            }
        }

        @Override
        public void onMessage( final String data ) {
            System.out.println( "onMessage: data=" +data );

            // Relay message to other connected clients
            for ( final SampleWebSocket member: members ) {
                try {
                    member.connection.sendMessage( data );
                } catch ( final IOException e ) {
                    e.printStackTrace();
                }
            }
        }

    }
}
于 2012-10-28T11:21:32.923 に答える