2

携帯電話（Android）とサーバーの間に単純なソケットを作成しました。

電話はサーバーに接続できますが、お互いにデータを送信または読み取ることができます。

クライアント（電話側）に使用するコードは次のとおりです。

private static void connect(String url, int port)
{
    do
    {
        try
        {
            socket = new Socket(url, port);
            input = socket.getInputStream();
            output = socket.getOutputStream();
            inputstream = new DataInputStream(input);
            outputstream = new DataOutputStream(output);
            isConnected = true;
        }
        catch (Exception e)
        {
            try
            {
                Thread.sleep(100);
            }
            catch (Exception ex) {}
        }
    }
    while (!isConnected);
}

public static String sendToServer(String json)
{       
    try
    {
        connect(Constants.SERVER_HOST, Constants.SERVER_PORT);

        if (isConnected)
        {
            Log.e("SOCKET MNGR", "[SOCKET] Sending " + json);
            outputstream.writeInt(json.getBytes().length);
            outputstream.write(json.getBytes());

            int arrLength = inputstream.readInt();
            if (arrLength > 0)
            {
                byte[] fromServer = new byte[arrLength];
                inputstream.read(fromServer, 0, fromServer.length);
                String content = new String( Base64.decode(new String(fromServer)) );
                Log.e("SOCKET MNGR", "[SOCKET] Reading " + content);
                return content;
            }
        }
    }
    catch (Exception e)
    {
        e.printStackTrace();
    }       

    return null;
}

そして私のサーバー用のもの：

public Client(Socket socket)
{
    try
    {
        this.socket = socket;
        this.input = this.socket.getInputStream();
        this.output = this.socket.getOutputStream();
        this.inputstream = new DataInputStream(this.input);
        this.outputstream = new DataOutputStream(this.output);
    }
    catch (Exception e) {}
}

public void run()
{
    while (true)
    {
        try
        {
            int arrLength = inputstream.readInt();
            byte[] fromClient = new byte[arrLength];
            inputstream.read(fromClient, 0, fromClient.length);
            String request = new String(fromClient);
            String read = new String( Base64.decode(request) );
            String[] data = request.split("###");

            if (data.length == 2 && data[0].equals("commit"))
            {
                CommitInterface.commit(data[1], true);
                outputstream.writeInt(0);
                outputstream.write(new byte[] {});
            }
            else if (data.length == 3 && data[0].equals("evaluate"))
            {
                EvaluateInterface.eval(data[1], data[2].equals("true") ? true : false);
                outputstream.writeInt(0);
                outputstream.write(new byte[] {});
            }
            else if (data.length == 2 && data[0].equals("publish"))
            {
                String content = PublishInterface.publish(new Vector<String>(Arrays.asList(data[1].split("|"))));
                String encoded = Base64.encode(content.getBytes());
                outputstream.writeInt(content.getBytes().length);
                outputstream.write(content.getBytes());
            }
        }
        catch (Exception e)
        {
            this.disconnect();
        }
    }
}

携帯電話でこの機能を使用するとsendToServer、次のログが表示されます。

06-29 13:26:05.823: E/Kramer(1781): [SOCKET] Sending commit###{"user":"me"}
06-29 13:26:05.823: W/System.err(1781): java.io.EOFException
06-29 13:26:05.823: W/System.err(1781):     at java.io.DataInputStream.readInt(DataInputStream.java:287)
06-29 13:26:05.823: W/System.err(1781):     at com.vodemki.network.KramerCommunicator.sendToServer(ServerCommunicator.java:78)
06-29 13:26:05.823: W/System.err(1781):     at com.vodemki.activities.PhoneBookActivity$6.run(PhoneBookActivity.java:298)

行78はint arrLength = inputstream.readInt();です。

このエラーが発生する理由はありますか？

ありがとう。

UDPを使用してみましたが、スマートフォンからコンテンツを読み取ることができませんでした。

私のコードは次のとおりです。

サーバ側：

public void run()
{
    byte[] inData = new byte[48];
    byte[] outData = new byte[48];
    String message;
    DatagramSocket socket;

    try
    {
        socket = new DatagramSocket(this.port);
        while (true)
        {
            DatagramPacket in = new DatagramPacket(inData, inData.length);
            socket.receive(in);
            InetAddress senderIP = in.getAddress();
            int senderPort = in.getPort();
            message = new String(in.getData(), 0, in.getLength());
            System.out.println("Got "+message+" from "+senderIP+":"+senderPort);
            outData = "Pong".getBytes();
            DatagramPacket out = new DatagramPacket(outData, outData.length, senderIP, senderPort);
            socket.send(out);
        }
    }
    catch (Exception e) {}
}

クライアント側（スマートフォン）：

public static String sendToServer(String json)
{       
    try
    {
        DatagramSocket socket = new DatagramSocket();
        InetAddress serverIP = InetAddress.getByName(Constants.SERVER_HOST);
        byte[] outData = ("Ping").getBytes();
        DatagramPacket out = new DatagramPacket(outData,outData.length, serverIP, Constants.SERVER_PORT);
        Log.e("kramer", "SENDING SOCKET");
        socket.send(out);
        Log.e("kramer", "SOCKET SENT");
        socket.close();
    }
    catch (Exception e)
    {
        e.printStackTrace();
    }       

    return null;
}

スマートフォンは2つの回線を正常にログに記録しますが、サーバーで何も受信されません。何か案が？

4

1 に答える 1

0

問題が解決しました。

ファイアウォールが着信接続をブロックしていました。ポートをUDPとして開いただけです。

于 2012-06-29T14:39:41.197 に答える