Android 프로 그래 밍 TCP 클 라 이언 트 구현 방법

이 사례 는 안 드 로 이 드 프로 그래 밍 이 TCP 클 라 이언 트 를 실현 하 는 방법 을 설명 한다.여러분 께 참고 하도록 공유 하 겠 습 니 다.구체 적 으로 는 다음 과 같 습 니 다.
프로젝트 에 TCP 클 라 이언 트 단 이 필요 하기 때 문 입 니 다.인터넷 에서 많은 예 를 찾 는 것 은 기본적으로 차단 방식 으로 완성 된다.
나의 실현 예:Activity 와 sever 에서 이 루어 지고 sever 에서 스 레 드 를 만들어 데 이 터 를 감청 합 니 다.데 이 터 를 받 아 라디오 를 통 해 Activity 에 보 내기;
서버 에서 이 루어 지지 않 았 습 니 다.TCP Socket 디 버 깅 도구 v 2.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>

더 많은 안 드 로 이 드 관련 내용 에 관심 이 있 는 독자 들 은 본 사이트 의 주 제 를 볼 수 있다.
본 고 에서 말 한 것 이 여러분 의 안 드 로 이 드 프로 그래 밍 에 도움 이 되 기 를 바 랍 니 다.