当前位置: 代码迷 >> Android >> Android自学进程—Socket的简单使用
  详细解决方案

Android自学进程—Socket的简单使用

热度:116   发布时间:2016-04-27 23:05:12.0
Android自学历程—Socket的简单使用

好几天没有更新博客了,一来学校的课实在是太多了,以前以为能轻松点的。。 二来在实例操作的过程中又遇到不少的问题,还好都解决了。。。再来,就是没多久的C语言二级考试,擦,还有二十天估计,还没来的及看!!!!时间管理这方面自己还欠缺了~~废话就这么多,下面开始我们的实例演练。 还有 求大神给建议,新手来学习。

 

这方面的知识不是孤立的,其中有关于,Socket编程,多线程的操作,以及I/O流的操作。当然,实现方法不止一种,这只是其中一种,给同是新手一点点思路。如果有什么推荐的话,欢迎指点!

 

先给大家看一下应用程序的界面,基本就能知道大致的功能了。

 图片大大的才好看。

 

activity_main.java

 1 <LinearLayout xmlns:android="http://schemas.android.com/apk/res/android" 2     xmlns:tools="http://schemas.android.com/tools" 3     android:layout_width="match_parent" 4     android:layout_height="match_parent" 5     android:orientation="vertical" 6     tools:context=".MainActivity"> 7  8     <EditText 9         android:id="@+id/editText"10         android:layout_width="match_parent"11         android:layout_height="wrap_content"12         android:hint="请输入要发送的内容"/>13     14     <Button15         android:id="@+id/button01"16         android:layout_width="match_parent"17         android:layout_height="wrap_content"18         android:text="连接"/>19 20     <Button21         android:id="@+id/button02"22         android:layout_width="match_parent"23         android:layout_height="wrap_content"24         android:text="发送"/>25 26     <ScrollView27         android:layout_width="match_parent"28         android:layout_height="wrap_content"29         android:scrollbars="vertical"30         android:fadingEdge="vertical">31         <TextView32             android:id="@+id/textView"33             android:layout_width="match_parent"34             android:layout_height="wrap_content"35             android:text="输出信息:"/>36     </ScrollView>37 38 </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://stackoverflow.com/questions/8191192/reaching-a-network-device-by-ip-and-port-using-the-android-emulator/8191487#8191487

http://stackoverflow.com/questions/10336637/how-do-i-socket-an-android-program-to-a-localhost-server

 

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,基本就这样。学习后还会再来分享,小白小白。。。。

 

1楼LubinLew
我工作这么多年 从来没用公司要求C语言二级证的,别浪费那100块钱
  相关解决方案