跨平台通信研究之一安卓系统与windows服务器socket通信
服务器端
import java.io.InputStream;
import java.io.OutputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class Server {
public static void main(String[] args) {
Server a = new Server();
a.dopost();
}
public void dopost() {
try {
ServerSocket s = new ServerSocket(12345);
while (true) {
Socket c = s.accept();
System.out.println(c.getInetAddress().getHostAddress());
InputStream in = c.getInputStream();
byte[] b = new byte[1024];
int length = in.read(b);
String ss = new String(b, 0, length);
System.out.println(ss);
System.out.println("33333333333333");
OutputStream oi = c.getOutputStream();
System.out.println("44444444444");
oi.write("服务器推送".getBytes("UTF-8"));
in.close();
oi.close();
c.close();
}
} catch (Exception e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
安卓客户端
package com.example.sss;
import java.io.InputStream;
import java.io.OutputStream;
import java.net.Socket;
import android.os.Bundle;
import android.app.Activity;
import android.view.Menu;
public class MainActivity extends Activity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
Thread t = new Thread(new Runnable() {
@Override
public void run() {
// TODO Auto-generated method stub
try {
Socket sk = new Socket("192.168.1.101", 12345);
OutputStream oi = sk.getOutputStream();
oi.write("客户端推送".getBytes());
InputStream is = sk.getInputStream();
byte[] b = new byte[1024];
int leng = is.read(b);
String ss = new String(b, 0, leng, "UTF-8");
System.out.println(ss);
oi.close();
is.close();
sk.close();
} catch (Exception e) {
e.printStackTrace();
// TODO: handle exception
}
}
});
t.start();
}
@Override
public boolean onCreateOptionsMenu(Menu menu) {
// Inflate the menu; this adds items to the action bar if it is present.
getMenuInflater().inflate(R.menu.main, menu);
return true;
}
}
