使用Service或IntentService进行Android Client / Server Socket通信

到目前为止,我能够在一个 Android设备(wifi tethering / hotspot)上启动服务器,并让客户端(另一个android)连接并向服务器发送消息.然后服务器回复了那个.我意识到我需要一种方法来保持服​​务器监听客户端,即使聊天应用程序没有运行.客户端应该能够发送消息,服务器应该收到此消息.@R_176_10675@用service或Intentservice来实现此目的吗？我不能从AsyncTask&服务……如何实现这个？一些示例代码会很棒.

这就是我的服务器的样子：

public class Server extends AsyncTask<Integer,Void,Socket> {

    private ServerSocket serverSocket;
    private TextView textView;
    private String incomingMsg;
    private String outgoingMsg;

    public Server(TextView textView) {
        this.textView = textView;
    }

    public void closeServer() {
        try {
            serverSocket.close();
        } catch (IOException E) {
            Log.d("Server","Closung the server caused a problem");
            e.printStackTrace();
        }       
    }


    @Override
    protected Socket doInBACkground(Integer... params) {

        try {
            serverSocket = new ServerSocket(params[0]);       

            //accept connections
            Socket socket = serverSocket.accept();

            BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            BufferedReader in = new BufferedReader(new InputStreamReader(socket.geTinputStream()));

            incomingMsg = in.readLine() + System.getProperty("line.separator");

            //send a message
            outgoingMsg = "You are connected to the Server" + System.getProperty("line.separator");
            out.write(outgoingMsg);
            out.flush();

            return socket;


        } catch (InterruptedioException E) {
            //if timeout occurs
            e.printStackTrace();

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

        } 
//      finally {
//          if (serverSocket != null) {
//              try {
//                  serverSocket.close();
//              } catch (IOException E) {
//                  e.printStackTrace();
//              }
//          }
//      }

        return null;
    }


    protected void onPostExecute(Socket socket) {

        if(socket != null) {
            try {

                Log.i("Server","Server received: " + incomingMsg);
                textView.setText("Server received: " + incomingMsg + "\n");

                textView.append("Server sent: " + outgoingMsg + "\n");
                Log.i("Server","Server sent: " + outgoingMsg);

                socket.close();

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

        } else {
            Log.d("Server","Can't communicate with the client!");
        }
    }
}

这是我的客户：

public class Client extends AsyncTask<Integer,Socket> {

    private WifiManager wifi;
    private Context context;
    private String outmsg;
    private String inMsg;

    public Client(Context context,WifiManager wifiManager) {
        this.context = context;
        this.wifi = wifiManager;
    }

    @Override
    protected Socket doInBACkground(Integer... params) {

        try {

            String gateway = intToIp(wifi.getDhcpInfo().gateway);
            Socket socket = new Socket(gateway,params[0]);

            BufferedReader in = new BufferedReader(new InputStreamReader(socket.geTinputStream()));
            BufferedWriter out = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));

            String ipadress = intToIp(wifi.getConnectionInfo().getIpaddress());

            outmsg = ",Client " + ipadress +" is connecTing!" + System.getProperty("line.separator"); 
            out.write(outmsg);
            out.flush();

            //accept server response
            inMsg = in.readLine() + System.getProperty("line.separator");

            return socket;

        } catch (UnkNownHostException E) {
            e.printStackTrace();
        } catch (IOException E) {
            e.printStackTrace();
        }

        return null; 
    }


    public String intToIp(int addr) {
        return  ((addr & 0xFF) + "." + 
                ((addr >>>= 8) & 0xFF) + "." + 
                ((addr >>>= 8) & 0xFF) + "." + 
                ((addr >>>= 8) & 0xFF));
    }


    protected void onPostExecute(Socket socket) {

        if(socket != null) {

            Log.i("Client","Client sent: " + outmsg);
            Toast.makeText(context,"\nClient sent: " + outmsg + "\n",Toast.LENGTH_LONG).show();

            Log.i("Client","Client received: " + inMsg);
            Toast.makeText(context,"Client received: " + inMsg + "\n",Toast.LENGTH_LONG).show();

        } else {
            Log.d("Client","Can't connect to server!");
            Toast.makeText(context,"Can't connect to server!",Toast.LENGTH_LONG).show();
        }           
    }
}

如何从服务器中取出服务？客户应该也是服务吗？