简单学习Android Socket的使用方法

这方面的知识不是孤立的，其中有关于，socket编程，多线程的操作，以及i/o流的操作。当然，实现方法不止一种，这只是其中一种，给同是新手一点点思路。如果有什么推荐的话，欢迎指点！
先给大家看一下应用程序的界面，基本就能知道大致的功能了。

activity_main.java

<linearlayout xmlns:android="http://schemas.android.com/apk/res/android"
 xmlns:tools="http://schemas.android.com/tools"
 android:layout_width="match_parent"
 android:layout_height="match_parent"
 android:orientation="vertical"
 tools:context=".mainactivity">

 <edittext
 android:id="@+id/edittext"
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:hint="请输入要发送的内容"/>

 <button
 android:id="@+id/button01"
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:text="连接"/>

 <button
 android:id="@+id/button02"
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:text="发送"/>

 <scrollview
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:scrollbars="vertical"
 android:fadingedge="vertical">
 <textview
  android:id="@+id/textview"
  android:layout_width="match_parent"
  android:layout_height="wrap_content"
  android:text="输出信息:"/>
 </scrollview>

</linearlayout>

界面很是简单。

下面我们需要一个服务器，和一个客户端。服务器，我用的是eclipse写的java的服务器；客户端，我用的是android studio写的。

package com.ryan.socketdemo01;

import android.os.handler;
import android.os.message;
import android.support.v7.app.appcompatactivity;
import android.os.bundle;
import android.util.log;
import android.view.menu;
import android.view.menuitem;
import android.view.view;
import android.widget.button;
import android.widget.edittext;
import android.widget.textview;
import android.widget.toast;

import java.io.ioexception;
import java.io.outputstream;
import java.io.unsupportedencodingexception;
import java.net.socket;

/**
 * 本实例功能： 客户端发送数据至客户端（动态输出数据）
 *
 */
public class mainactivity extends appcompatactivity implements view.onclicklistener{

 private button button01 = null;
 private button button02 = null;
 private edittext edittext = null;
 private textview textview = null;

 private static socket clientsocket = null;
 private byte[] msgbuffer = null;
 handler handler = new handler();


 private void initview() {
 button01 = (button) findviewbyid(r.id.button01);
 button02 = (button) findviewbyid(r.id.button02);
 edittext = (edittext) findviewbyid(r.id.edittext);
 textview = (textview) findviewbyid(r.id.textview);

 button01.setonclicklistener(this);
 button02.setonclicklistener(this);

 button01.setenabled(true);
 button02.setenabled(false);
 }


 @override
 protected void oncreate(bundle savedinstancestate) {
 super.oncreate(savedinstancestate);
 setcontentview(r.layout.activity_main);
 initview();

 }


 @override
 public void onclick(view v) {
 switch (v.getid()){
  case r.id.button01:
  // todo: 15-9-4 socket连接线程
  connectthread();
  break;
  case r.id.button02:
  // todo: 15-9-4 发送数据线程
  sendmsgthread();
  break;
 }
 }

 private void sendmsgthread() {

 final string text = edittext.gettext().tostring();
 try {
  msgbuffer = text.getbytes("utf-8");
 } catch (unsupportedencodingexception e) {
  e.printstacktrace();
 }

 new thread(new runnable() {
  @override
  public void run() {
  try {
   outputstream outputstream;
   //socket输出流
   outputstream = clientsocket.getoutputstream();

   outputstream.write(msgbuffer);
   outputstream.flush();
   outputstream.close();
  } catch (ioexception e) {
   e.printstacktrace();
  }
  handler.post(new runnable() {
   @override
   public void run() {
   textview.append("发送成功："+text+"\n");
   }
  });
  }
 }).start();
 }

 private void connectthread() {
 new thread(new runnable() {
  @override
  public void run() {
  try {
   clientsocket = new socket("10.0.2.2",9001);
   if (clientsocket.isconnected()){
   handler.post(new runnable() {
    @override
    public void run() {
    textview.append("连接成功！"+"\n");
    button01.setenabled(false);
    button02.setenabled(true);
    }
   });
   }else {
   handler.post(new runnable() {
    @override
    public void run() {
    textview.append("连接失败！"+"\n");
    }
   });
   }
  } catch (ioexception e) {
   e.printstacktrace();
  }
  }
 }).start();
 }

@override
 public boolean oncreateoptionsmenu(menu menu) {
 // inflate the menu; this adds items to the action bar if it is present.
 getmenuinflater().inflate(r.menu.menu_main, menu);
 return true;
 }

 @override
 public boolean onoptionsitemselected(menuitem item) {
 // handle action bar item clicks here. the action bar will
 // automatically handle clicks on the home/up button, so long
 // as you specify a parent activity in androidmanifest.xml.
 int id = item.getitemid();

 //noinspection simplifiableifstatement
 if (id == r.id.action_settings) {
  return true;
 }

 return super.onoptionsitemselected(item);
 }
}

这里我的线程使用方式是：

new thread (new runnable) {
 @override
 public void run() {
 }
}

  网上有人说这个方式很low，而且不好，但现在我只会这个，就连asynctask也还在学习中。 

还有一点，子线程更新主ui的方法：

我使用的是 handler.post();　　同样十分简单的使用方法。

handler handler = new handler();

handler.post(new runnable() {
   @override
   public void run() {
   textview.append("发送成功："+text+"\n");
   }
  });

关于几种子线程更新主ui的方法，我以后会再写一篇博客。我现在已经知道了不下4中方法，还没实地操作。 

再来就是关于i/o流操作的方法：

这里我不做详细介绍，大家自行google！什么你不会google？ 自行找fq工具吧～～

这里我说一下我对于i/o的简单使用方法。

万物始于最初的，inputstream，outputstream，他的方法只有reader()和write()。再其之上的，例如什么使用最多的bufferedreader对象，都是再其之上的升级包装，穿了个衣服，变得更加华丽而已。他的专业术语就是——装饰者模式，感兴趣的可以去翻翻资料。

最初，我对inputstream和outputstream的方法不是很明了，经常错将inputstream用上write()的方法。 不知在哪里看到这么一段话，i/o流的操作实质是相对于socket，serversocket连接后产生的数据流管道，reader与write是读取与写入的意思，是相对于那个数据流管道进行操作的。即读取管道里的信息，写入信息至管道。不知道这样大家动不动。 

最后就是我们要学习的socket。

他的使用也很简单，建立一个socket对象，设置ip和端口，获取其i/o流。

clientsocket = new socket("10.0.2.2",9001);

outputstream = clientsocket.getoutputstream();

到这里基本的使用方法就这么多。

说说我在这其中遇到的问题：

1.模拟器连接java服务器连接不上。ip设置不对，我最开始设置的ip是 127.0.0.1。 解决的连接：

http://*.com/questions/8191192/reaching-a-network-device-by-ip-and-port-using-the-android-emulator/8191487#8191487

 

 2.忘记设置manifest，或者系统提供的android.permission.internet全是大写的！！说来滑稽，但我就是遇到这样的问题，系统自动完成的代码提示，全是大写的，我以为就是那样呢，结果明明应该是小写。

<uses-permission android:name="android.permission.internet" />

忘记贴上java服务器的代码了，补上。

/**
 * 本实例功能：接受服务器发来的数据
 */
public class main {

  public static void main(string[] args) {
    // todo auto-generated method stub
    new serverlistener().start();
  }

}

 

import java.io.bufferedreader;
import java.io.ioexception;
import java.io.inputstream;
import java.io.inputstreamreader;
import java.io.unsupportedencodingexception;
import java.net.serversocket;
import java.net.socket;

import javax.swing.joptionpane;


public class serverlistener extends thread{

  private socket clientsocket = null;
  private serversocket serversocket = null;
  private inputstream inputstream = null;
  private byte[] buffer = null;

  @override
  public void run() {
    // todo auto-generated method stub

    try {
      serversocket = new serversocket(9001);
      system.out.println("端口已开启，等待连接中〜〜");
      //block
      clientsocket = serversocket.accept();
      system.out.println("已有用户连接");
      inputstream = clientsocket.getinputstream();

      bufferedreader br = new bufferedreader(new inputstreamreader(inputstream));
      string str;

      while((str = br.readline())!= null){
        system.out.println(str);
      }

    }catch (ioexception e) {
      // todo auto-generated catch block
      e.printstacktrace();
    }finally{
      try {
        inputstream.close();
        serversocket.close();
      } catch (ioexception e) {
        // todo auto-generated catch block
        e.printstacktrace();
      }
    }


  }

}

这是服务器端就收到的数据：

 

 

ok，基本就这样。

以上就是本文的全部内容，希望对大家的学习有所帮助。