当前位置：文档库 › android3.0 socket通讯实现代码

android3.0 socket通讯实现代码

Android 3.0 sdk 下编译通过：

Android 客户端：

package com.test;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import https://www.wendangku.net/doc/1c1253892.html,.InetAddress;

import https://www.wendangku.net/doc/1c1253892.html,.Socket;

import android.app.Activity;

import android.content.Intent;

import android.os.Bundle;

import android.util.Log;

import android.view.View;

import android.view.View.OnClickListener;

import android.widget.Button;

import android.widget.EditText;

import android.widget.TextView;

public class Socket_10_13Activity extends Activity {

private TextView mTextView;

private EditText mEditText;

private TextView tx1;

private String returnMsg;

private Button mbutton;

/** Called when the activity is first created. */ @Override

public void onCreate(Bundle savedInstanceState) {

super.onCreate(savedInstanceState);

setContentView(https://www.wendangku.net/doc/1c1253892.html,yout.main);

initView();

startServer();

requestServer();

}

//向socket 服务端发送信息

public void requestServer()

{

mbutton.setOnClickListener(new OnClickListener()

{

public void onClick(View v)

{

setTitle("接返回信息");

StartTCP startTCP = new StartTCP();

startTCP.start();

}

});

}

//初始化界面

public void initView()

{

mbutton = (Button) findViewById(R.id.Button01);

mEditText = (EditText) findViewById(R.string.EditText01);

mTextView = (TextView) findViewById(R.string.TextView01);

tx1 = (TextView) findViewById(R.id.tx);

tx1.setText("显示返回值");

}

//启动socket 服务

public void startServer()

{

// 创建Intent

Intent intent = new Intent();

// 设置Action属性

intent.setAction("com.test.MyService");

// 启动该Service

startService(intent);

}

//显示返回信息

public void getMessage(String Msg)

{

tx1.setText(Msg);

}

public class StartTCP extends Thread

{

public void run()

{

Socket socket = null;

try

{

// 指定Server的IP地址

InetAddress serverAddr =

InetAddress.getByName("127.0.0.1");// TCPServer.SERVERIP

System.out.println(serverAddr);

Log.d("TCP", "C: Connecting...");

// 应用Server的IP和端口建立Socket对象

// socket = new Socket(serverAddr, 8000);

socket = new Socket("127.0.0.1", 8000);

String message = "---Test_Socket_Android---";

Log.d("TCP", "C: Sending: '" + message + "'");

// 将信息通过这个对象来发送给Server

PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())), true);

// 接受服务器信息

BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));

// 得到服务器信息

String returnValue = in.readLine();

getMessage(returnValue);

Log.i("return message ", returnValue);

out.println(returnValue);

out.flush();

} catch (Exception e)

{

Log.e("TCP", "S: Error", e);

} finally

{

try

{

socket.close();

} catch (Exception e)

{

// TODO Auto-generated catch block

e.printStackTrace();

}

Android 服务端：

通过android service 启动socket 服务

package com.test;

import android.app.Service;

import android.content.Intent;

import android.os.IBinder;

import android.util.Log;

import android.widget.Toast;

public class MyService extends Service{

// 可以返回null，通常返回一个有aidl定义的接口

public IBinder onBind(Intent intent)

{

Log.i("SERVICE", "onBind..............");

Toast.makeText(MyService.this, "onBind..............", Toast.LENGTH_LONG).show();

return null;

}

// Service创建时调用

public void onCreate()

{

Log.i("SERVICE", "onCreate..............");

Toast.makeText(MyService.this, "onCreate..............", Toast.LENGTH_LONG).show();

}

// 当客户端调用startService()方法启动Service时，该方法被调用

public void onStart(Intent intent, int startId)

{

Thread t = new Thread(new Server());

t.start();

Toast.makeText(MyService.this, "S: Receiving...",

Toast.LENGTH_LONG).show();

Log.i("SERVICE", "startd..............");

}

// 当Service不再使用时调用

public void onDestroy()

{

Log.i("SERVICE", "onDestroy..............");

}

启动 socket 服务

package com.test;

import java.io.BufferedReader;

import java.io.BufferedWriter;

import java.io.InputStreamReader;

import java.io.OutputStreamWriter;

import java.io.PrintWriter;

import https://www.wendangku.net/doc/1c1253892.html,.ServerSocket;

import https://www.wendangku.net/doc/1c1253892.html,.Socket;

public class Server implements Runnable

{

public static final String SERVERIP = "127.0.0.1";

public static final int SERVERPORT = 8000;

public void run()

{

try

{

System.out.println("S: Connecting...");

ServerSocket serverSocket = new ServerSocket(SERVERPORT);

while (true)

{

// 等待接受客户端请求

Socket client = serverSocket.accept();

System.out.println(" local port : "

+ serverSocket.getLocalPort() + " , intet address "

+ serverSocket.getInetAddress() + " , local socker"

+ serverSocket.getLocalSocketAddress());

System.out.println("S: Receiving...");

try

{

// 接受客户端信息

BufferedReader in = new BufferedReader(new InputStreamReader(client.getInputStream()));

Socket socket = null;

// 发送消息

PrintWriter out = new PrintWriter(new BufferedWriter(

new

OutputStreamWriter(client.getOutputStream())),

true);

// 设置返回信息

out.println("my name is server");

out.flush();

} catch (Exception e)

{

System.out.println("S: Error");

e.printStackTrace();

} finally

{

client.close();

System.out.println("S: Done.");

}

} catch (Exception e)

{

System.out.println("S: Error");

e.printStackTrace();

}

public static void main(String[] args)

{

Thread desktopServerThread = new Thread(new Server());

desktopServerThread.start();

}

Main.xml:

xmlns:android="https://www.wendangku.net/doc/1c1253892.html,/apk/res/android"

android:orientation="vertical"