利用Socket与服务器端交互的简单Android范例代码

利用Socket与服务器端交互的简单Android范例代码

在Android中可以直接利用java中的Socket与ServerSocket构建socket通信。代码的运行环境：pc端：普通pc，作为服务器，在5648端口进行监听。

代码运行一切正常，客户端发送的文字将在服务器端接收并显示，服务器每接收到客户端的一行文字，就会返回一个从0开始递增的整数，此整数将在客户端显示出来。pc端代码：

packagetest;

importjava.io.BufferedReader;

importjava.io.IOException;

importjava.io.InputStream;

importjava.io.InputStreamReader;

importjava.io.OutputStream;

importjava.io.PrintWriter;

.ServerSocket;

.Socket;

publicclassTestimplementsRunnable{

/**

*@paramargs

*/

intmax=10;//最大开启线程数

inti=0;//回复数字

inttemp;

ServerSocketserverSocket;

Socketsocket[];

publicTest(){

try{

serverSocket=newServerSocket(5648);//在5648端口进行

侦听

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

System.out.println("can'tinitateServerSocket!");

return;

}

socket=newSocket[max];

@Override

System.out.println("waitingforconnect");

try{

null){

while((socket[i]=serverSocket.accept())!=

temp=i;

i++;

newThread(this).start();

端的连接，就会开启一个工作线程

//每侦听到一个客户

}

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

}

}

publicstaticvoidmain(String[]args){

newTest();

}

publicvoidrun(){

Socketsk=socket[temp];

System.out.println("accept:"+sk.getInetAddress().getHostAddres

s());

InputStreamis=null;

OutputStreamos=null;

BufferedReaderbr=null;

PrintWriterpw=null;

try{

is=sk.getInputStream();

os=sk.getOutputStream();

br=newBufferedReader(newInputStreamReader(is));

pw=newPrintWriter(os);

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

try{

sk.close();

}catch(IOExceptione1){

//TODOAuto-generatedcatchblock

e1.printStackTrace();

}

return;

}

Stringstr;

try{

intm=0;

while((str=br.readLine())!=null){

System.out.println(str);

pw.println(m);

pw.flush();

m++;

}

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

}

}

}

</pre>

android设备客户端代码：MainActivity.java;代码：

importjava.io.BufferedReader;

importjava.io.IOException;

importjava.io.InputStreamReader;

importjava.io.PrintWriter;

.Socket;

.UnknownHostException;

importandroid.app.Activity;

importandroid.os.Bundle;

importandroid.os.Handler;

importandroid.util.Log;

importandroid.view.Menu;

importandroid.view.View;

importandroid.view.View.OnClickListener;

importandroid.widget.Button;

importandroid.widget.EditText;

importandroid.widget.Toast;

publicclassMainActivityextendsActivityimplementsOnClickListener,Runnable{

privateButtonbutton;

privateEditTexteditText;

privateSocketsocket;

privatePrintWriterpw;

privateBufferedReaderbr;

privateHandlerhandler;

@Override

publicvoidonCreate(BundlesavedInstanceState){

super.onCreate(savedInstanceState);

setContentView(R.layout.activity_main);

handler=newHandler();

button=(Button)findViewById(R.id.button);

button.setOnClickListener(this);

editText=(EditText)findViewById(R.id.edittext);

try{

socket=newSocket("",5648);

//连接到的5648端口

}catch(UnknownHostExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

Log.e("socket","unknownhost");

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

Log.e("socket","ioexecption");

}

if(socket==null){

Log.e("socket","null");

}

else

try{

pw=newPrintWriter(socket.getOutputStream());

br=newBufferedReader(newInputStreamReader(socket.getInputStream()));

if(pw!=null&&br!=null){

newThread(this).start();

}

}catch(IOExceptione){

//TODOAuto-generatedcatchblock

e.printStackTrace();

}

}

@Override

publicbooleanonCreateOptionsMenu(Menumenu){

getMenuInflater().inflate(R.menu.activity_main,menu);

returntrue;

}

publicvoidonClick(Viewview){

if(view==button){

Stringstr;

str=editText.getText().toString();

pw.println(str);

pw.flush();

}

}

publicvoidrun(){

try{

Stringstr;

while((str=br.readLine())!=null){

finalStrings=str;

handle