Android编程实现TCP客户端的方法

本文实例讲述了Android编程实现TCP客户端的方法。分享给大家供大家参考，具体如下：
因为项目上需要实现一个TCP Client 端；在网上找好多例子基本上都是阻塞方式完成；
我的实现例子：由Activity 及sever 来实现，在sever 创建一个线程来监听接受数据。收到数据，通过广播发送给Activity;
服务端我没有去实现，你可以下载TCP Socket 调试工具v2.2；创建个9005端口；客户端：访问的IP为10.0.2.2

AnetTest.java：

/*** Copyright 2010 archfree**/package com.archfree.demo;import android.app.Activity;import android.content.BroadcastReceiver;import android.content.ComponentName;import android.content.Context;import android.content.Intent;import android.content.IntentFilter;import android.content.ServiceConnection;import android.os.Bundle;import android.os.IBinder;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 AnetTest extends Activity { /** * 通过ServiceConnection的内部类实现来连接Service和Activity * */ public static final String TAG = "AnetTest"; private static final boolean DEBUG = true;// false private String msg = ""; private UpdateReceiver mReceiver; private Context mContext; private ReceiveMessage mReceiveMessage; // 实现一个 BroadcastReceiver，用于接收指定的 Broadcast public class UpdateReceiver extends BroadcastReceiver { @Override public void onReceive（Context context, Intent intent） { if （DEBUG） Log.d（TAG, "onReceive: " + intent）; msg = intent.getStringExtra（"msg"）; System.out.println（"recv:" + msg）; // System.out.println（）; （（EditText） findViewById（R.id.tv_recv））.append（msg + "/n"）; } } private ServiceConnection serviceConnection = new ServiceConnection（） { @Override public void onServiceConnected（ComponentName name, IBinder service） { mReceiveMessage = （（ReceiveMessage.LocalBinder） service） .getService（）; if （DEBUG） Log.d（TAG, "on serivce connected"）; } @Override public void onServiceDisconnected（ComponentName name） { mReceiveMessage = null; } }; /** Called when the activity is first created. */ @Override public void onCreate（Bundle savedInstanceState） { super.onCreate（savedInstanceState）; setContentView（R.layout.main）; // 实例化自定义的 BroadcastReceiver mReceiver = new UpdateReceiver（）; IntentFilter filter = new IntentFilter（）; // 为 BroadcastReceiver 指定 action ，使之用于接收同 action 的广播 filter.addAction（"com.archfree.demo.msg"）; // 以编程方式注册 BroadcastReceiver 。配置方式注册 BroadcastReceiver 的例子见 // AndroidManifest.xml 文件 // 一般在 OnStart 时注册，在 OnStop 时取消注册 this.registerReceiver（mReceiver, filter）; mContext = AnetTest.this; /** * Button bn_conn bn_send bn_bind bn_unbind */ // Button bn_conn = （Button） findViewById（R.id.bn_conn）; Button bn_send = （Button） findViewById（R.id.bn_send）; Button bn_bind = （Button） findViewById（R.id.bn_bind）; Button bn_unbind = （Button） findViewById（R.id.bn_unbind）; EditText tv_recv = （EditText） findViewById（R.id.tv_recv）; /** * EditText et_send */ EditText et_send = （EditText） findViewById（R.id.et_send）; /** * bn_send on click */ bn_send.setOnClickListener（new OnClickListener（） { public void onClick（View arg0） { // TODO （（EditText） findViewById（R.id.tv_recv））.clearComposingText（）; mReceiveMessage.SendMessageToServer（"0001058512250000190010900005300010001354758032278512 460029807503542 0613408000011"）; } }）; /** * bn_bind on click */ bn_bind.setOnClickListener（new OnClickListener（） { public void onClick（View arg0） { // TODO Intent i = new Intent（）; Bundle bundle = new Bundle（）; bundle.putString（"chatmessage", （（EditText） findViewById（R.id.et_send））.getText（） .toString（））; i.putExtras（bundle）; System.out.println（" send onclick"）; bindService（new Intent（"com.archfree.demo.ReceiveMessage"）, serviceConnection, BIND_AUTO_CREATE）; } }）; /** * bn_unbind on click */ bn_unbind.setOnClickListener（new OnClickListener（） { public void onClick（View arg0） { // TODO mContext.unbindService（serviceConnection）; } }）; /** * Activity和本地服务交互,需要使用bind和unbind方法 * */ } @Override protected void onDestroy（） { // TODO Auto-generated method stub super.onDestroy（）; unbindService（serviceConnection）; unregisterReceiver（mReceiver）; }}

ReceiveMessage.java 参考网络资源，修改；

package com.archfree.demo;import java.io.IOException;import java.net.InetSocketAddress;import java.nio.ByteBuffer;import java.nio.CharBuffer;import java.nio.channels.SocketChannel;import java.nio.charset.CharacterCodingException;import java.nio.charset.Charset;import java.nio.charset.CharsetDecoder;import android.app.Notification;import android.app.NotificationManager;import android.app.PendingIntent;import android.app.Service;import android.content.Context;import android.content.Intent;import android.os.Binder;import android.os.IBinder;public class ReceiveMessage extends Service {// @Override// public int onStartCommand（Intent intent, int flags, int startId） {// // TODO Auto-generated method stub// return super.onStartCommand（intent, flags, startId）;// }private SocketChannel client = null;private InetSocketAddress isa = null;private String message = "";public void onCreate（） {System.out.println（"----- onCreate---------"）;super.onCreate（）;ConnectToServer（）;StartServerListener（）;}public void onDestroy（） {super.onDestroy（）;DisConnectToServer（）;}public void onStart（Intent intent, int startId） {System.out.println（"----- onStart---------"）;super.onStart（intent, startId）;}/* * IBinder方法 , LocalBinder 类,mBinder接口这三项用于 * Activity进行Service的绑定，点击发送消息按钮之后触发绑定 并通过Intent将Activity中的EditText的值 * 传送到Service中向服务器发送 */public IBinder onBind（Intent intent） {System.out.println（"----- onBind---------"）;//message = intent.getStringExtra（"chatmessage"）;//if （message.length（） > 0） {//SendMessageToServer（message）;//}return mBinder;}public class LocalBinder extends Binder {ReceiveMessage getService（） {return ReceiveMessage.this;}}private final IBinder mBinder = new LocalBinder（）;// 用于链接服务器端public void ConnectToServer（） {try {client = SocketChannel.open（）;//isa = new InetSocketAddress（"10.0.2.2", 9005）;isa = new InetSocketAddress（"211.141.230.246", 6666）;client.connect（isa）;client.configureBlocking（false）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;}}// 断开与服务器端的链接public void DisConnectToServer（） {try {client.close（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;}}// 启动服务器端的监听线程，从Server端接收消息public void StartServerListener（） {ServerListener a = new ServerListener（）;a.start（）;}// 向Server端发送消息public void SendMessageToServer（String msg） {System.out.println（"Send:" + msg）;try {ByteBuffer bytebuf = ByteBuffer.allocate（1024）;bytebuf = ByteBuffer.wrap（msg.getBytes（"UTF-8"））;client.write（bytebuf）;bytebuf.flip（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;System.out.println（" SendMessageToServer IOException==="）;}}private void shownotification（String tab） {System.out.println（"shownotification=====" + tab）;NotificationManager barmanager = （NotificationManager） getSystemService（Context.NOTIFICATION_SERVICE）;Notification msg = new Notification（android.R.drawable.stat_notify_chat, "A Message Coming！",System.currentTimeMillis（））;PendingIntent contentIntent = PendingIntent.getActivity（this, 0,new Intent（this, AnetTest.class）, PendingIntent.FLAG_ONE_SHOT）;msg.setLatestEventInfo（this, "Message", "Message:" + tab, contentIntent）;barmanager.notify（0, msg）;}// 发送广播信息private void sendMsg（String msg）{// 指定广播目标的 action （注：指定了此 action 的 receiver 会接收此广播）Intent intent = new Intent（"com.archfree.demo.msg"）;// 需要传递的参数intent.putExtra（"msg", msg）;// 发送广播this.sendBroadcast（intent）;}private class ServerListener extends Thread {//privateByteBuffer buf = ByteBuffer.allocate（1024）;public void run（） {try {// 无线循环，监听服务器,如果有不为空的信息送达，则更新Activity的UIwhile （true） {ByteBuffer buf = ByteBuffer.allocate（1024）;//buf.clear（）;client.read（buf）;buf.flip（）;Charset charset = Charset.forName（"UTF-8"）;CharsetDecoder decoder = charset.newDecoder（）;CharBuffer charBuffer;charBuffer = decoder.decode（buf）;String result = charBuffer.toString（）;if （result.length（） > 0）{// recvData（result）;sendMsg（result）;//System.out.println（"+++++="+result）;//shownotification（result）;}// System.out.println（"++++++++++++++++++="+result）;}} catch （CharacterCodingException e） {// TODO Auto-generated catch blocke.printStackTrace（）;} catch （IOException e） {// TODO Auto-generated catch blocke.printStackTrace（）;}}}}

AndroidManifest.xml

<?xml version="1.0" encoding="utf-8"?><manifest xmlns:android="http://schemas.android.com/apk/res/android"package="com.archfree.demo" android:versionCode="1"android:versionName="1.0"><application android:icon="@drawable/icon" android:label="@string/app_name"><activity android:name=".AnetTest" android:label="@string/app_name"><intent-filter><action android:name="android.intent.action.MAIN" /><category android:name="android.intent.category.LAUNCHER" /></intent-filter></activity>

更多关于Android相关内容感兴趣的读者可查看本站专题：《Android通信方式总结》、《Android调试技巧与常见问题解决方法汇总》、《Android开发入门与进阶教程》、《Android多媒体操作技巧汇总（音频,视频,录音等）》、《Android基本组件用法总结》、《Android视图View技巧总结》、《Android布局layout技巧总结》及《Android控件用法总结》
希望本文所述对大家Android程序设计有所帮助。