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 block
      e.printStackTrace();
    }
  }
  // 断开与服务器端的链接
  public void DisConnectToServer() {
    try {
      client.close();
    } catch (IOException e) {
      // TODO Auto-generated catch block
      e.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 block
      e.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 {
    //private  ByteBuffer buf = ByteBuffer.allocate(1024);
    public void run() {
      try {
        // 无线循环,监听服务器,如果有不为空的信息送达,则更新Activity的UI
        while (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 block
        e.printStackTrace();
      } catch (IOException e) {
        // TODO Auto-generated catch block
        e.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程序设计有所帮助。

(0)

相关推荐

  • Android TCP 文件客户端与服务器DEMO介绍

    主要功能是: 1.TCP服务器提供文件下载服务,服务器支持多线程. 2.TCP Client从服务器上下载指定的文件,Client也支持多线程. 首先是服务器,服务器是在PC机上,JAVA运行环境,主要参考网上的代码,自己做了支持多线程处理,代码如下: 复制代码 代码如下: //file:DownloadServer.java import java.net.*;import java.io.*;class ServerOneDownload extends Thread {    privat

  • Android使用socket创建简单TCP连接的方法

    本文实例讲述了Android使用socket创建简单TCP连接的方法.分享给大家供大家参考,具体如下: 不管是在Java还是Android编程中,通信都是及其重要的一部分.有连接的socket编程,重要性自然毋庸置疑. 这里以一个简单的demo演示一个最基本的socket编程. 先写服务端.服务端是Java代码.笔者懒得装eclipse等编程软件,就是直接notepad编程,dos运行的.服务端一般是新建一个绑定端口的serversocket,监听客户端请求(死循环监听).当接收到客户端消息时,

  • Android编程使用HTTP协议与TCP协议实现上传文件的方法

    本文实例讲述了Android编程使用HTTP协议与TCP协议实现上传文件的方法.分享给大家供大家参考,具体如下: Android上传文件有两种方式,第一种是基于Http协议的HttpURLConnection,第二种是基于TCP协议的Socket. 这两种方式的区别是使用HttpURLConnection上传时内部有缓存机制,如果上传较大文件会导致内存溢出.如果用TCP协议Socket方式上传就会解决这种弊端. HTTP协议HttpURLConnection 1. 通过URL封装路径打开一个Ht

  • android的UDP编程实例

    一.有的手机不能直接接收UDP包,可能是手机厂商在定制Rom的时候把这个功能给关掉了.1.可先在oncreate()方法里面实例化一个WifiManager.MulticastLock 对象lock:具体如下: 复制代码 代码如下: WifiManager manager = (WifiManager) this                .getSystemService(Context.WIFI_SERVICE);WifiManager.MulticastLock lock= manag

  • Android中实现TCP和UDP传输实例

    TCP和UDP在网络传输中非常重要,在Android开发中同样重要. 首先我们来看一下什么是TCP和UDP. 什么是TCP? TCP:Transmission Control Protocol 传输控制协议TCP是一种面向连接(连接导向)的.可靠的.基于字节流的运输层(Transport layer)通信协议,由IETF的RFC 793说明(specified).在简化的计算机网络OSI模型中,它完成第四层传输层所指定的功能.应用层向TCP层发送用于网间传输的.用8位字节表示的数据流,然后TCP

  • Android下使用TCPDUMP实现数据抓包教程

    如果想分析Android下 某个APP的网络数据交互,需要在Android手机上抓包,最常用的抓包工具非tcpdump莫属,用tcpdump生成Wireshark识别的 pcap文件,然后将pcap文件下载到电脑上,用电脑上的Wireshark加载pcap文件,通过Wireshark分析tcpdump抓取的数据. 一.安装tcpdump 为Android手机安装tcpdump,首先必须将Android手机root,现在市面上常用的root工具都很傻瓜很强大,推荐使用root精灵,将手机root以

  • Android实现TCP断点上传 后台C#服务接收

    终端实现大文件上传一直都是比较难的技术,其中涉及到后端与前端的交互,稳定性和流量大小,而且实现原理每个人都有自己的想法,后端主流用的比较多的是Http来实现,因为大多实现过断点下载.但稳定性不能保证,一旦断开,无法续传.所以得采用另一种流行的做法,TCP上传大文件. 网上查找了一些资料,大多数是断点下载,然后就是单独的C#端的上传接收,或是HTTP的,或是只有android端的,由于任务紧所以之前找的首选方案当然是Http先来实现文件上传,终端采用Post方法,将文件直接传至后端,后端通过Fil

  • Android网络编程之UDP通信模型实例

    什么是Android UDP? UDP是User Datagram Protocol的简称,中文名是用户数据包协议,是OSI参考模型中一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务.它是IETF RFC 768是UDP的正式规范.在网络中它与TCP协议一样用于处理数据包.在OSI模型中,在第四层-传输层,处于IP协议的上一层.UDP有不提供数据报分组.组装和不能对数据包的排序的缺点,也就是说,当报文发送之后,是无法得知其是否安全完整到达的.UDP用来支持那些需要在计算机之间传输数据

  • Android编程实现TCP、UDP客户端通信功能示例

    本文实例讲述了Android编程实现TCP.UDP客户端通信功能.分享给大家供大家参考,具体如下: 在进行Android开发的过程中,免不了,要开发TCP/UDP通讯的程序,下面这两段代码,分别介绍了TCP/UCP通过的一个实例: 代码一 TCP通讯: private void tcpdata() { try { Socket s = new Socket("192.168.0.25", 65500); // outgoing stream redirect to socket Out

  • Android中使用tcpdump、wireshark进行抓包并分析技术介绍

    本文主要介绍如何使用tcpdump和wireshark对Android应用程序进行抓包并分析,需要说明的是在抓包之前,你的Android设备必须root过了,另外你的电脑必须有Android SDK环境. 下载并安装tcpdump tcpdump链接:http://www.tcpdump.org/ 选择一个版本下载并解压提取出其中呃tcpdump文件,然后push到你的手机上去: 复制代码 代码如下: adb push c:\tcpdump /data/local/tcpdump 进一步操作:

  • Android实现TCP客户端接收数据的方法

    本文实例讲述了Android实现TCP客户端接收数据的方法.分享给大家供大家参考,具体如下: 配合log4net使用,用来接收调试信息.因此,此客户端只管通过TCP接收字符串数据,然后显示在界面上. 接收TCP数据 try { Socket s = new Socket("192.168.1.5", 8240); InputStream inputStream = s.getInputStream(); DataInputStream input = new DataInputStre

随机推荐