2015-01-06 143 views
1

從服務器返回客戶端時出現問題。 此代碼只發送數據從android客戶端到服務器,我不能讓它從服務器發送回到android客戶端。我試着把Inputstream閱讀器放在客戶端代碼中,它似乎不起作用。 這裏是代碼: 客戶端代碼:Android客戶端/ Java服務器通信,無法從服務器接收數據

package com.lakj.comspace.simpletextclient; 

import java.io.IOException; 
import java.io.PrintWriter; 
import java.net.Socket; 
import java.net.UnknownHostException; 

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; 

/** 
* This is a simple Android mobile client 
* This application read any string massage typed on the text field and 
* send it to the server when the Send button is pressed 
* Author by Lak J Comspace 
* 
*/ 
public class SlimpleTextClientActivity extends Activity { 

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

@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 

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

     public void onClick(View v) { 
      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 { 

      client = new Socket("10.0.2.2", 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; 
} 

} 

服務器代碼:

package com.lakj.comspace.simpletextserver; 

import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.net.ServerSocket; 
import java.net.Socket; 

/** 
* This is a simple server application. This server receive a string message 
* from the Android mobile phone and show it on the console. 
* Author by Lak J Comspace 
*/ 
public class SimpleTextServer { 

private static ServerSocket serverSocket; 
private static Socket clientSocket; 
private static InputStreamReader inputStreamReader; 
private static BufferedReader bufferedReader; 
private static String message; 

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(message); 
      inputStreamReader.close(); 
      clientSocket.close(); 

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

} 

} 

回答

0

套接字是 「雙向的」。您需要getInputStream在客戶端,getOutputStream在服務器端在相同的端口/套接字上。 添加到客戶端:

client = new Socket(IP, PORT); // second connection to server 
inputStreamReader = new InputStreamReader(client.getInputStream()); 
bufferedReader = new BufferedReader(inputStreamReader); //get the client message 
message = bufferedReader.readLine(); 
inputStreamReader.close();             
socket.close();   //closing the connection 

&服務器:

printWriter = new PrintWriter(clientSocket.getOutputStream(), true); 
printWriter.write("Returned back from server to client \n");  //write the message to output stream 
printWriter.flush();                  
printWriter.close();  
inputStreamReader.close();           
clientSocket.close();