3

私の英語でごめんなさい。

Android でネイティブ アプリをプログラムして、インタラクティブな通信のためにサーバーに接続したいと考えています。Websocket テグノロジーはこれに最適です。IP 192.168.1.250 のラップトップに Tomcat 7.0.39 をインストールして動作させました。エコー、スネークなどの例を試してみましたが、ws://localhost:8080/.... および ws://192.168.1.250:8080/... を使用して正常に動作します。

サーバーに接続するためにEclipseでアウトバーンを使用しています。autobahn クライアント websocket サンプルを使用して Android モバイルに apk をインストールしましたが、ws://echo.websocket.org と完全に接続します。

問題は、Android から私のサーバー (私のラップトップ) への接続が機能しないことです。Android から ws://echo.websocket.org までは正常に動作します (autobahn の例はうまく動作すると思います)。

サーバーとクライアントの間を移動する情報を集中的に処理する必要があるため、サーバー側で JavaScript を使用することはできません。データベース、ファイルなどを操作するには Java サーブレットなどが必要です。

なにが問題ですか?ファイアウォールはオフで、wireshark は、Android クライアントがラップトップ サーバーに接続しようとする方法を示しています (wireshark 情報をよく理解していません) が、接続が失われます。

これは私のAndroidコードです:

    package com.example.autobahnandroiddemo;

    import de.tavendo.autobahn.WebSocketConnection;
    import de.tavendo.autobahn.WebSocketException;
    import de.tavendo.autobahn.WebSocketHandler;
    import android.app.Activity;
    import android.content.SharedPreferences;
    import android.os.Bundle;
    import android.util.Log;
    import android.view.Gravity;
    import android.view.Menu;
    import android.view.MenuInflater;
    import android.view.MenuItem;
    import android.view.View;
    import android.widget.Button;
    import android.widget.EditText;
    import android.widget.TextView;
    import android.widget.Toast;


    public class MainActivity extends Activity {

       static final String TAG = "de.tavendo.autobahn.echo";
       private static final String PREFS_NAME = "AutobahnAndroidEcho";

       static EditText mHostname;
       static EditText mPort;
       static TextView mStatusline;
       static Button mStart;

       static EditText mMessage;
       static Button mSendMessage;

       private SharedPreferences mSettings;

       private void alert(String message) {
          Toast toast = Toast.makeText(getApplicationContext(), message,         Toast.LENGTH_SHORT);
          toast.setGravity(Gravity.CENTER_VERTICAL | Gravity.CENTER_HORIZONTAL, 0, 0);
          toast.show();
       }

       private void loadPrefs() {

          mHostname.setText(mSettings.getString("hostname", ""));
          mPort.setText(mSettings.getString("port", "9000"));
       }

       private void savePrefs() {

          SharedPreferences.Editor editor = mSettings.edit();
          editor.putString("hostname", mHostname.getText().toString());
          editor.putString("port", mPort.getText().toString());
          editor.commit();
       }

       private void setButtonConnect() {
          mHostname.setEnabled(true);
          mPort.setEnabled(true);
          mStart.setText("Connect");
          mStart.setOnClickListener(new Button.OnClickListener() {
             public void onClick(View v) {
                start();
             }
          });
       }

       private void setButtonDisconnect() {
          mHostname.setEnabled(false);
          mPort.setEnabled(false);
          mStart.setText("Disconnect");
          mStart.setOnClickListener(new Button.OnClickListener() {
             public void onClick(View v) {
                mConnection.disconnect();
             }
          });
       }

       private final WebSocketConnection  mConnection = new WebSocketConnection();

       private void start() {

          final String wsuri = mHostname.getText() + ":" + mPort.getText();

          mStatusline.setText("Status: Connecting to " + wsuri + " ..");

          setButtonDisconnect();

          try {
             mConnection.connect(wsuri, new WebSocketHandler() {
                @Override
                public void onOpen() {
                   mStatusline.setText("Status: Connected to " + wsuri);
                   savePrefs();
                   mSendMessage.setEnabled(true);
                   mMessage.setEnabled(true);
                }

                @Override
                public void onTextMessage(String payload) {
                   alert("Got echo: " + payload);
                }

                @Override
                public void onClose(int code, String reason) {
                   alert("Connection lost.");
                   mStatusline.setText("Status: Ready.");
                   setButtonConnect();
                   mSendMessage.setEnabled(false);
                   mMessage.setEnabled(false);
                }
             });
          } catch (WebSocketException e) {

             Log.d(TAG, e.toString());
          }
       }

       @Override
       public void onCreate(Bundle savedInstanceState) {

          super.onCreate(savedInstanceState);
          setContentView(R.layout.activity_main);

          mHostname = (EditText) findViewById(R.id.hostname);
          mPort = (EditText) findViewById(R.id.port);
          mStatusline = (TextView) findViewById(R.id.statusline);
          mStart = (Button) findViewById(R.id.start);
          mMessage = (EditText) findViewById(R.id.msg);
          mSendMessage = (Button) findViewById(R.id.sendMsg);

          mSettings = getSharedPreferences(PREFS_NAME, 0);
          loadPrefs();

          setButtonConnect();
          mSendMessage.setEnabled(false);
          mMessage.setEnabled(false);

          mSendMessage.setOnClickListener(new Button.OnClickListener() {
             public void onClick(View v) {
                mConnection.sendTextMessage(mMessage.getText().toString());
             }
          });
       }

       @Override
       protected void onDestroy() {
           super.onDestroy();
           if (mConnection.isConnected()) {
              mConnection.disconnect();
           }
       }

       @Override
       public boolean onCreateOptionsMenu(Menu menu) {
           MenuInflater inflater = getMenuInflater();
           inflater.inflate(R.menu.main_menu, menu);
           return true;
       }

       @Override
       public boolean onOptionsItemSelected(MenuItem item) {
          switch (item.getItemId()) {
             case R.id.quit:
                finish();
                break;
             default:
                return super.onOptionsItemSelected(item);
          }
          return true;
       }

    }

そして、これは私のサーブレットTomcatコードです:

    package servlets;

    import org.apache.catalina.websocket.MessageInbound;
    import org.apache.catalina.websocket.StreamInbound;
    import org.apache.catalina.websocket.WebSocketServlet;
    import org.apache.catalina.websocket.WsOutbound;

    import javax.servlet.http.HttpServletRequest;
    import java.io.IOException;
    import java.nio.ByteBuffer;
    import java.nio.CharBuffer;

    public class SimpleWebSocketServlet extends WebSocketServlet {
    private static final long serialVersionUID = 1L;

        @Override
        protected StreamInbound createWebSocketInbound(String string, HttpServletRequest hsr) {
            return new MessageInbound() {

                @Override
                protected void onBinaryMessage(ByteBuffer bb) throws IOException {

                }

                @Override
                protected void onTextMessage(CharBuffer cb) throws IOException {
                    System.out.println(cb.toString());
                    WsOutbound outbound = getWsOutbound();
                    outbound.writeTextMessage(cb);
                }
            };
        }

    }

何が悪いのかわからない。ウェブソケットを介してサーバー(同様の技術のJavaサーブレット)と組み合わせてAndroidクライアントを使用する別のソリューションがありますか?ありがとう

4

1 に答える 1

0

onCreateに接続するコードを入れるべきだったと思います。

于 2013-05-20T17:24:31.693 に答える