【问题标题】:Socket from Server (java app) to Android app从服务器(java 应用程序)到 Android 应用程序的套接字
【发布时间】:2014-11-06 11:52:07
【问题描述】:

我有一个问题,我不知道是否可行。

我有一个作为客户端套接字的 Android 应用。

这是在 Android 应用中向服务器发送消息的代码:

private class SendMessage extends AsyncTask<Void, Void, Void> {

    @Override
    protected Void doInBackground(Void... params) {
        try {
            System.out.println("envia mensaje");
            client = new Socket("ip of server", 4444); // connect to the server
            printwriter = new PrintWriter(client.getOutputStream(), true);
            printwriter.write(messsage); // write the message to output stream

            printwriter.flush();
            printwriter.close();
            client.close(); // closing the connection

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }

}

同时在Android App中,在4445端口创建一个socket:

private class SocketServerThread extends Thread {

    static final int SocketServerPORT = 4445;
    int count = 0;

    @Override
    public void run() {
        try {
            serverSocket = new ServerSocket(SocketServerPORT);
            SlimpleTextClientActivity.this.runOnUiThread(new Runnable() {

                @Override
                public void run() {
                    System.out.println("I'm waiting here: "
                            + serverSocket.getLocalPort());
                }
            });

            while (true) {
                Socket socket = serverSocket.accept();
                count++;
                message += "#" + count + " from " + socket.getInetAddress()
                        + ":" + socket.getPort() + "\n";

                SlimpleTextClientActivity.this.runOnUiThread(new Runnable() {

                    @Override
                    public void run() {
                        System.out.println(message);
                    }
                });

                /*SocketServerReplyThread socketServerReplyThread = new SocketServerReplyThread(
                        socket, count);
                socketServerReplyThread.run();*/

            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}

这是在 4444 端口创建套接字的服务器代码:

public static void main(String[] args) {
    try {
        serverSocket = new ServerSocket(4444); // Server socket

    } catch (IOException e) {
        System.out.println("Could not listen on port: 4444");
    }

    System.out.println("Server started. Listening to the port 4444");


    while (true) {
        try {



            clientSocket = serverSocket.accept(); // accept the client connection
            inputStreamReader = new InputStreamReader(clientSocket.getInputStream());
            bufferedReader = new BufferedReader(inputStreamReader); // get the client message
            message = bufferedReader.readLine();



            System.out.println("Dirección entrante"+clientSocket.getInetAddress());
            //System.out.println("Dirección entrante2"+clientSocket.get());

            System.out.println(message);


                ip_a = clientSocket.getInetAddress().toString().substring(clientSocket.getInetAddress().toString().indexOf("/")+1, clientSocket.getInetAddress().toString().length());
                        //message.substring(message.indexOf(":")+1, message.length()).trim();
                System.out.println("realiza conexión a ip:#"+ip_a+"#");
                messsage = "enviado desde el servidor"; // get the text message on the text field


                SendMessage(ip_a);




            inputStreamReader.close();
            clientSocket.close();

        } catch (IOException ex) {
            System.out.println("Problem in message reading");
        }
    }

}

这可以正常工作,但我想通过套接字拥有的 IP 从服务器向 Android 设备发送消息。

我尝试使用 clientSocket.getInetAddress() 和 clientSocket.getRemoteSocketAddress(),但不起作用。我在 4445 端口的 Android 应用程序中创建了一个套接字,但服务器无法连接到 android 应用程序的套接字。

你能帮帮我吗?

提前致谢

【问题讨论】:

  • 为什么要创建两个服务器?请解释一下,因为我不清楚您的整个设置和目标。
  • 我希望 2 个应用程序可以通过服务器 java 应用程序进行通信。
  • 好的。但请花时间解释整个场景。我必须从代​​码中发现吗?

标签: java android sockets tcp communication


【解决方案1】:

好的,我会试试的。

这是我的服务器应用程序:

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Enumeration;


public class SimpleTextServer {

private static ServerSocket serverSocket;
private static Socket clientSocket;
private static InputStreamReader inputStreamReader;
private static BufferedReader bufferedReader;
private static String message;
private static Socket client;
private static String messsage;
private static PrintWriter printwriter;
static String ip_a;

public static void main(String[] args) {
    try {
        serverSocket = new ServerSocket(4444); // Server socket

    } catch (IOException e) {
        System.out.println("Could not listen on port: 4444");
    }

    System.out.println("Server started. Listening to the port 4444");
    System.out.println("Server started. Listening to the port 4444:"+getIpAddress());

    while (true) {
        try {



            clientSocket = serverSocket.accept(); // accept the client connection
            inputStreamReader = new InputStreamReader(clientSocket.getInputStream());
            bufferedReader = new BufferedReader(inputStreamReader); // get the client message
            message = bufferedReader.readLine();



            System.out.println("Dirección entrante"+clientSocket.getInetAddress());
            //System.out.println("Dirección entrante2"+clientSocket.get());

            System.out.println(message);


                ip_a = clientSocket.getInetAddress().toString().substring(clientSocket.getInetAddress().toString().indexOf("/")+1, clientSocket.getInetAddress().toString().length());
                        //message.substring(message.indexOf(":")+1, message.length()).trim();
                System.out.println("realiza conexión a ip:#"+ip_a+"#");
                messsage = "enviado desde el servidor"; // get the text message on the text field


                SendMessage(ip_a);




            inputStreamReader.close();
            clientSocket.close();

        } catch (IOException ex) {
            System.out.println("Problem in message reading");
        }
    }

}






public static void SendMessage(String ip) {


        try {
            System.out.println("comienza a enviar mensaje");
            client = new Socket(ip, 4445); // connect to the server
            printwriter = new PrintWriter(client.getOutputStream(), true);
            printwriter.write(messsage); // write the message to output stream

            printwriter.flush();
            printwriter.close();
            client.close(); // closing the connection

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();

    }

}

public static String getIpAddress() {
    String ip = "";
    try {
        Enumeration<NetworkInterface> enumNetworkInterfaces = NetworkInterface
                .getNetworkInterfaces();
        while (enumNetworkInterfaces.hasMoreElements()) {
            NetworkInterface networkInterface = enumNetworkInterfaces
                    .nextElement();
            Enumeration<InetAddress> enumInetAddress = networkInterface
                    .getInetAddresses();
            while (enumInetAddress.hasMoreElements()) {
                InetAddress inetAddress = enumInetAddress.nextElement();

                if (inetAddress.isSiteLocalAddress()) {
                    ip += "SiteLocalAddress: " 
                            + inetAddress.getHostAddress() + "\n";
                }

            }

        }

    } catch (SocketException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
        ip += "Something Wrong! " + e.toString() + "\n";
    }

    return ip;
}

}

这是我在 Android 应用中的活动:

package com.lakj.comspace.simpletextclient;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.InetAddress;
import java.net.NetworkInterface;
import java.net.ServerSocket;
import java.net.Socket;
import java.net.SocketException;
import java.net.UnknownHostException;
import java.util.Enumeration;

import android.app.Activity;
import android.os.AsyncTask;
import android.os.Bundle;
import android.view.Menu;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;


public class SlimpleTextClientActivity extends Activity {

private Socket client;
private PrintWriter printwriter;
private EditText textField;
private Button button;
private String messsage;
//ServerSocket serverSocket;

private static ServerSocket serverSocket;
private static Socket clientSocket;

private static InputStreamReader inputStreamReader;
private static BufferedReader bufferedReader;
private static String message;


@Override
protected void onCreate(Bundle savedInstanceState) {
    super.onCreate(savedInstanceState);
    setContentView(R.layout.activity_slimple_text_client);

    textField = (EditText) findViewById(R.id.editText1); // reference to the text field
    button = (Button) findViewById(R.id.button1); // reference to the send button



    System.out.println("IP DE CLIENTE EMULADOR: "+getIpAddress());
    Thread socketServerThread = new Thread(new SocketServerThread());
    socketServerThread.start();


    //myClientTask.execute();

    // Button press event listener
    button.setOnClickListener(new View.OnClickListener() {

        public void onClick(View v) {
            System.out.println("ENVIA MENSAJE BOTON");
            messsage = textField.getText().toString(); // get the text message on the text field
            textField.setText(""); // Reset the text field to blank
            SendMessage sendMessageTask = new SendMessage();
            sendMessageTask.execute();
        }
    });
}

private class SendMessage extends AsyncTask<Void, Void, Void> {

    @Override
    protected Void doInBackground(Void... params) {
        try {
            System.out.println("envia mensaje");
            client = new Socket("ip de servidor", 4444); // connect to the server
            printwriter = new PrintWriter(client.getOutputStream(), true);
            printwriter.write(messsage); // write the message to output stream

            printwriter.flush();
            printwriter.close();
            client.close(); // closing the connection

        } catch (UnknownHostException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
        return null;
    }

}

@Override
public boolean onCreateOptionsMenu(Menu menu) {
    // Inflate the menu; this adds items to the action bar if it is present.
    getMenuInflater().inflate(R.menu.slimple_text_client, menu);
    return true;
}

private class SocketServerThread extends Thread {

    static final int SocketServerPORT = 4445;
    int count = 0;

    @Override
    public void run() {
        try {
            serverSocket = new ServerSocket(SocketServerPORT);
            SlimpleTextClientActivity.this.runOnUiThread(new Runnable() {

                @Override
                public void run() {
                    System.out.println("I'm waiting here: "
                            + serverSocket.getLocalPort());
                }
            });

            while (true) {
                Socket socket = serverSocket.accept();
                count++;
                message += "#" + count + " from " + socket.getInetAddress()
                        + ":" + socket.getPort() + "\n";

                SlimpleTextClientActivity.this.runOnUiThread(new Runnable() {

                    @Override
                    public void run() {
                        System.out.println(message);
                    }
                });

                /*SocketServerReplyThread socketServerReplyThread = new SocketServerReplyThread(
                        socket, count);
                socketServerReplyThread.run();*/

            }
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }

}



@Override
protected void onDestroy() {
    super.onDestroy();

    if (serverSocket != null) {
        try {
            serverSocket.close();

        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
}

private String getIpAddress() {
    String ip = "";
    try {
        Enumeration<NetworkInterface> enumNetworkInterfaces = NetworkInterface
                .getNetworkInterfaces();
        while (enumNetworkInterfaces.hasMoreElements()) {
            NetworkInterface networkInterface = enumNetworkInterfaces
                    .nextElement();
            Enumeration<InetAddress> enumInetAddress = networkInterface
                    .getInetAddresses();
            while (enumInetAddress.hasMoreElements()) {
                InetAddress inetAddress = enumInetAddress.nextElement();

                if (inetAddress.isSiteLocalAddress()) {
                    ip += "SiteLocalAddress: " 
                            + inetAddress.getHostAddress() + "\n";
                }

            }

        }

    } catch (SocketException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
        ip += "Something Wrong! " + e.toString() + "\n";
    }

    return ip;
}

}

如果我运行 android 应用程序,消息会发送到服务器,然后服务器会显示它。

但是,服务器无法连接到 Android。 IP 是不可访问的。不知道为什么……

【讨论】:

    猜你喜欢
    • 2015-07-20
    • 1970-01-01
    • 1970-01-01
    • 2011-12-20
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多