我有c + +套接字服务器和Android客户端。服务器在一段时间间隔后不断向客户端发送数据。问题是如何实现这个获取Android客户端上的数据如何监视Android客户端上的套接字服务器活动？
socket = new Socket("xxx.xxx.xxx.x", xxxx); // I connect
.... socket.getInputStream(); // Get first input stream
如何使它不断接收数据？我试过这样的事情（true）{..socket.getInputStream（）;了Thread.sleep（...）; }它没有帮助
请注意，您只需打开一次输入流。然后，如果您对输入流执行read()操作，它将会阻塞（当然，如果使用阻塞读取（blocking vs non-blocking read））。
你可以找到关于Java Socket编程此信息：link
你可以找到丢失的例子为socket编程Android平台上的位置：link
例如：
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
String line = "";
while (true) {
line = br.readLine(); // at this line, execution will stop until data is received
System.out.println("The read line is: " + line);
}
br.close();
我明白如何使用套接字，如何连接，发送和接收形成。问题是如何实现客户端连续监听服务器并显示收到的信息 –
好了，让我直接说明：打开套接字流并执行'read（）'。执行'read（）'的线程将阻塞并且不执行任何操作，直到您向其发送数据为止。当在数据流中接收到数据时，线程会“唤醒”，并且您可以处理接收到的数据（例如，您可以将其放在屏幕上）。我添加了一些编辑的答案。 – overbet13
生成服务器的数据是一个图像，我通过这段代码得到它* Bitmap bmp = BitmapFactory.decodeStream（socket.getInputStream（））*;如何在服务器发送后获取此映像？对不起，没有正确的解释。 –
你可以使用此Webstart Application并创建一个本地服务器，通过提供您的IP地址和端口 ，并可以在下面的代码中使用相同的IP地址和端口作为客户... ...！你可以发送和接收消息。并且在AndroidManifest中提供INTERNET权限。
MainActivity.java
import java.io.ByteArrayOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.InetSocketAddress;
import java.net.Socket;
import java.net.SocketAddress;
import android.app.Activity;
import android.graphics.Bitmap;
import android.graphics.BitmapFactory;
import android.os.AsyncTask;
import android.os.Bundle;
import android.os.Environment;
import android.util.Base64;
import android.util.Log;
import android.view.View;
import android.view.View.OnClickListener;
import android.widget.Button;
import android.widget.EditText;
import android.widget.ImageView;
import android.widget.TextView;
public class MainActivity extends Activity {
Button btnStart, btnSend, disconnect;
TextView textStatus;
EditText message, ipAddress, port;
ImageView image;
NetworkTask networktask;
String ip, prt;
Socket nsocket;
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.main);
btnStart = (Button)findViewById(R.id.btnStart);
disconnect = (Button)findViewById(R.id.bDisconnect);
btnSend = (Button)findViewById(R.id.btnSend);
textStatus = (TextView)findViewById(R.id.textStatus);
image = (ImageView)findViewById(R.id.ivBit);
message = (EditText) findViewById(R.id.message);
ipAddress = (EditText)findViewById(R.id.ipAddress);
port = (EditText)findViewById(R.id.port);
btnStart.setOnClickListener(btnStartListener);
btnSend.setOnClickListener(btnSendListener);
disconnect.setOnClickListener(new OnClickListener() {
public void onClick(View v) {
// TODO Auto-generated method stub
try {
nsocket.close();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
});
// networktask = new NetworkTask(ip, prt); //Create initial instance so SendDataToNetwork doesn't throw an error.
}
private OnClickListener btnStartListener = new OnClickListener() {
public void onClick(View v){
disconnect.setVisibility(View.VISIBLE);
btnStart.setVisibility(View.GONE);
ipAddress.setEnabled(false);
port.setEnabled(false);
ip = ipAddress.getText().toString();
prt = port.getText().toString();
System.out.println("IPADDRESS :::::::" + ip);
System.out.println("PORT :::::::" + prt);
networktask = new NetworkTask(ip, prt); //New instance of NetworkTask
networktask.execute();
}
};
private OnClickListener btnSendListener = new OnClickListener() {
public void onClick(View v){
textStatus.setText("Sending Message to AsyncTask.");
networktask.SendDataToNetwork(message.getText().toString() + "\n");
}
};
public class NetworkTask extends AsyncTask<Void, byte[], Boolean> {
//Network Socket
InputStream nis; //Network Input Stream
OutputStream nos; //Network Output Stream
String data = ""; //Data Received
String ip, prt;
public NetworkTask(String ip, String prt) {
// TODO Auto-generated constructor stub
this.ip = ip;
this.prt = prt;
}
@Override
protected void onPreExecute() {
Log.i("AsyncTask", "onPreExecute");
}
@Override
protected Boolean doInBackground(Void... params) { //This runs on a different thread
boolean result = false;
try {
Log.i("AsyncTask", "doInBackground: Creating socket");
SocketAddress sockaddr = new InetSocketAddress(ip, Integer.parseInt(prt)); //192.168.2.102 118.139.161.101
nsocket = new Socket();
nsocket.connect(sockaddr, 500); //10 second connection timeout
if (nsocket.isConnected()) {
nis = nsocket.getInputStream();
nos = nsocket.getOutputStream();
Log.i("AsyncTask", "doInBackground: Socket created, streams assigned");
Log.i("AsyncTask", "doInBackground: Waiting for inital data...");
byte[] buffer = new byte[4096];
int read = nis.read(buffer, 0, 4096); //This is blocking
while(read != -1){
byte[] tempdata = new byte[read];
System.arraycopy(buffer, 0, tempdata, 0, read);
publishProgress(tempdata);
Log.i("AsyncTask", "doInBackground: Got some data");
read = nis.read(buffer, 0, 4096); //This is blocking
}
}
} catch (IOException e) {
e.printStackTrace();
Log.i("AsyncTask", "doInBackground: IOException");
result = true;
} catch (Exception e) {
e.printStackTrace();
Log.i("AsyncTask", "doInBackground: Exception");
result = true;
} finally {
try {
nis.close();
nos.close();
nsocket.close();
} catch (IOException e) {
e.printStackTrace();
} catch (Exception e) {
e.printStackTrace();
}
Log.i("AsyncTask", "doInBackground: Finished");
}
return result;
}
public void SendDataToNetwork(String cmd) { //You run this from the main thread.
try {
if (nsocket.isConnected()) {
Log.i("AsyncTask", "SendDataToNetwork: Writing received message to socket");
nos.write(cmd.getBytes());
} else {
Log.i("AsyncTask", "SendDataToNetwork: Cannot send message. Socket is closed");
}
} catch (Exception e) {
Log.i("AsyncTask", "SendDataToNetwork: Message send failed. Caught an exception");
}
}
@Override
protected void onProgressUpdate(byte[]... values) {
if (values.length > 0) {
Log.i("AsyncTask", "onProgressUpdate: " + values[0].length + " bytes received.");
data += new String(values[0]);
textStatus.setText(data);
System.out.println("DATA RECEIVED..........." + (data));
}
}
@Override
protected void onCancelled() {
Log.i("AsyncTask", "Cancelled.");
disconnect.setVisibility(View.VISIBLE);
btnStart.setVisibility(View.GONE);
ipAddress.setEnabled(true);
port.setEnabled(true);
}
@Override
protected void onPostExecute(Boolean result) {
if (result) {
Log.i("AsyncTask", "onPostExecute: Completed with an Error.");
textStatus.setText("There was a connection error.");
} else {
Log.i("AsyncTask", "onPostExecute: Completed.");
}
disconnect.setVisibility(View.GONE);
btnStart.setVisibility(View.VISIBLE);
ipAddress.setEnabled(true);
port.setEnabled(true);
}
}
@Override
protected void onDestroy() {
super.onDestroy();
networktask.cancel(true); //In case the task is currently running
}
}
main.xml中
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:layout_width="fill_parent"
android:layout_height="fill_parent"
android:orientation="vertical" >
<EditText
android:id="@+id/ipAddress"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:digits="."
android:inputType="number" />
<EditText
android:id="@+id/port"
android:layout_width="100dp"
android:layout_height="wrap_content"
android:digits="."
android:inputType="number" />
<Button
android:id="@+id/bDisconnect"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:visibility="gone"
android:text="Disconnect" />
<Button
android:id="@+id/btnStart"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Start AsyncTask" >
</Button>
<EditText
android:id="@+id/message"
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:ems="10"
android:inputType="textMultiLine" >
</EditText>
<Button
android:id="@+id/btnSend"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Send Message" >
</Button>
<ScrollView
android:layout_width="wrap_content"
android:layout_height="wrap_content" >
<LinearLayout
android:layout_width="wrap_content"
android:layout_height="wrap_content" >
<TextView
android:id="@+id/textStatus"
android:layout_width="fill_parent"
android:layout_height="wrap_content"
android:text="Status Goes Here"
android:textSize="24sp" />
<ImageView
android:id="@+id/ivBit"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
</LinearLayout>
</ScrollView>
</LinearLayout>
这里插座编程基础知识的一个很好的例子为Android看看这个链接，可以帮助ü HTTP ：//thinkandroid.wordpress.com/2010/03/27/incorporating-socket-programming-into-your-applications/ – Aamirkhan