文档章节

Android的三种网络通讯方式详解

茗香墨语
 茗香墨语
发布于 2015/11/10 15:15
字数 1526
阅读 4726
收藏 159

1.标准Java接口

java.net.*提供与联网有关的类,包括流、数据包套接字(socket)、Internet协议、常见Http处理等。比如:创建URL,以及URLConnection/HttpURLConnection对象、设置链接参数、链接到服务器、向服务器写数据、从服务器读取数据等通信。这些在Java网络编程中均有涉及,我们看一个简单的socket编程,实现服务器回发客户端信息。

下面用个例子来说明:

A、客户端:

新建Android项目工程:SocketForAndroid(这个随意起名字了吧,我是以这个建立的!)

下面是main_activity.xml的代码:

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:orientation="vertical">

    <TextView
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="@string/hello" />

    <EditText
        android:id="@+id/message"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:hint="@string/hint" />

    <Button
        android:id="@+id/send"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:text="@string/send" />
</LinearLayout>

MainActivity.java的代码入下:

package com.yaowen.socketforandroid;

import android.os.Bundle;

import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.Socket;

public class MainActivity extends AppCompatActivity {
    private EditText message;
    private Button send;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        //初始化两个UI控件
        message = (EditText) findViewById(R.id.message);
        send = (Button) findViewById(R.id.send);
        //设置发送按钮的点击事件响应
        send.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {
                Socket socket = null;
                //获取message输入框里的输入的内容
                String msg = message.getText().toString() + "\r\n";
                try {
                    //这里必须是192.168.3.200,不可以是localhost或者127.0.0.1
                    socket = new Socket("192.168.3.200", 18888);
                    PrintWriter out = new PrintWriter(
                            new BufferedWriter(
                                    new OutputStreamWriter(
                                            socket.getOutputStream()
                                    )
                            ), true);
                    //发送消息
                    out.println(msg);
                    //接收数据
                    BufferedReader in = new BufferedReader(
                        new InputStreamReader(
                            socket.getInputStream()
                        )
                    );
                    //读取接收的数据
                    String msg_in = in.readLine();
                    if (null != msg_in) {
                        message.setText(msg_in);
                        System.out.println(msg_in);
                    } else {
                        message.setText("接收的数据有误!");
                    }
                    //关闭各种流
                    out.close();
                    in.close();
                } catch (IOException e) {
                    e.printStackTrace();
                } finally {
                    try {
                        if (null != socket) {
                            //socket不为空时,最后记得要把socket关闭
                            socket.close();
                        }
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }
        });
    }
}

最后别忘记添加访问网络权限:

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

B、服务端:

package service;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.io.PrintWriter;
import java.net.ServerSocket;
import java.net.Socket;
public class ServerAndroid implements Runnable {
 @Override
 public void run() {
  Socket socket = null;
  try {
   ServerSocket server = new ServerSocket(18888);
   // 循环监听客户端链接请求
   while (true) {
    System.out.println("start...");
    // 接收请求
    socket = server.accept();
    System.out.println("accept...");
    // 接收客户端消息
    BufferedReader in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
    String message = in.readLine();
    System.out.println(message);
    // 发送消息,向客户端
    PrintWriter out = new PrintWriter(new BufferedWriter(new OutputStreamWriter(socket.getOutputStream())),
      true);
    out.println("Server:" + message);
    // 关闭流
    in.close();
    out.close();
   }
  } catch (IOException e) {
   e.printStackTrace();
  } finally {
   if (null != socket) {
    try {
     socket.close();
    } catch (IOException e) {
     e.printStackTrace();
    }
   }
  }
 }
 // 启动服务器
 public static void main(String[] args) {
  Thread server = new Thread(new ServerAndroid());
  server.start();
 }
}

C、启动服务器,控制台会打印出“start...”字符串!

D、运行Android项目文件,如下图:

在输入框里输入如下字符串,点发送按钮:

服务器收到客户端发来的消息并打印到控制台:

 

 2、Apache接口

对于大部分应用程序而言JDK本身提供的网络功能已远远不够,这时就需要Android提供的Apache HttpClient了。它是一个开源项目,功能更加完善,为客户端的Http编程提供高效、最新、功能丰富的工具包支持。
下面我们以一个简单例子来看看如何使用HttpClient在Android客户端访问Web。
首先,要在你的机器上搭建一个web应用test,有两个很简单的PHP文件:hello_get.php和hello_post.php!
内容如下:

hello_get.php的代码如下:

<html>
 <body>
  Welcome <?php echo $_GET["name"]; ?><br>
  You connected this page on : <?php echo $_GET["get"]; ?>
 </body>
</html>

hello_post.php的代码如下:

<html>
<body>
Welcome <?php echo $_POST["name"]; ?><br>
You connected this page on : <?php echo $_POST["post"]; ?>
</body>
</html>

在原来的Android项目里新建一个Apache活动类:Apache.java,代码如下:

package com.yaowen.socketforandroid;

import android.os.Bundle;

import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.TextView;

import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import java.util.ArrayList;
import java.util.List;

/**
 * Created by YAOWEN on 2015/11/10.
 */
public class ApacheActivity extends AppCompatActivity implements View.OnClickListener {

    private TextView textView;
    private Button get1, post1;

    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.apache);
        

        textView = (TextView) findViewById(R.id.textView);
        get1 = (Button) findViewById(R.id.get);
        post1 = (Button) findViewById(R.id.post);

        get1.setOnClickListener(this);
        post1.setOnClickListener(this);

    }

    @Override
    public void onClick(View v) {
        if (v.getId() == R.id.get) {
            //注意:此处ip不能用127.0.0.1或localhost,Android模拟器已将它自己作为了localhost

            String url = "http://192.168.3.200/test/hello_get.php?name=yaowen&get=GET";
            textView.setText(get(url));
        }
        if (v.getId() == R.id.post) {

            String url="http://192.168.3.200/test/hello_post.php";
            textView.setText(post(url));
        }

    }

    /**
     * 以post方式发送请求,访问web
     *
     * @param url web地址
     * @return 响应数据
     */
    private String post(String url) {
        BufferedReader reader = null;
        StringBuffer sb = null;
        String result = "";
        HttpClient client = new DefaultHttpClient();
        HttpPost requset = new HttpPost(url);
        //保存要传递的参数
        List<NameValuePair> params = new ArrayList<NameValuePair>();
        //添加参数
        params.add(new BasicNameValuePair("name", "yaowen"));
        params.add(new BasicNameValuePair("post","POST"));

        try {
            HttpEntity entity = new UrlEncodedFormEntity(params, "utf-8");
            requset.setEntity(entity);
            HttpResponse response = client.execute(requset);
            if (response.getStatusLine().getStatusCode() == 200) {
                System.out.println("post success");
                reader = new BufferedReader(new InputStreamReader(response.getEntity().getContent()));
                sb = new StringBuffer();
                String line = "";
                String NL = System.getProperty("line.separator");
                while ((line = reader.readLine()) != null) {
                    sb.append(line);
                }
            }

        } catch (UnsupportedEncodingException e) {
            e.printStackTrace();
        } catch (ClientProtocolException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (null != reader) {
                try {
                    reader.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }

            }
            if (null != sb) {
                result = sb.toString();
            }
        }

        return result;
    }

    /**
     * 以get方式发送请求,访问web
     *
     * @param url web地址
     * @return 响应数据
     */
    private static String get(String url) {
        BufferedReader bufferedReader = null;
        StringBuffer sb = null;
        String result = "";
        HttpClient client = new DefaultHttpClient();
        HttpGet request = new HttpGet(url);
        //发送请求,得到响应
        try {
            HttpResponse response = client.execute(request);
            //请求成功
            if (response.getStatusLine().getStatusCode() == 200) {
                bufferedReader = new BufferedReader(
                        new InputStreamReader(
                                response.getEntity()
                                        .getContent()
                        )
                );
                sb = new StringBuffer();
                String line = "";
                String NL = System.getProperty("line.separator");
                while ((line = bufferedReader.readLine()) != null) {
                    sb.append(line);
                }
            }
        } catch (IOException e) {
            e.printStackTrace();
        } finally {
            if (null != bufferedReader) {
                try {
                    bufferedReader.close();
                    //bufferedReader=null;
                } catch (IOException e) {
                    e.printStackTrace();
                }

            }
            if (null != sb) {
                result = sb.toString();
            }
        }
        return result;
    }
}

新建一个apache.XML文件,如下:

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
    android:layout_width="fill_parent"
    android:layout_height="fill_parent"
    android:orientation="vertical">

    <TextView
        android:id="@+id/textView"
        android:layout_width="fill_parent"
        android:layout_height="wrap_content"
        android:gravity="center"
        android:text="通过按钮选择不同方式访问网页" />

    <Button
        android:id="@+id/get"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="get" />

    <Button
        android:id="@+id/post"
        android:layout_width="match_parent"
        android:layout_height="wrap_content"
        android:text="post" />
</LinearLayout>

结果运行如下:

 

 

 

 3.android.net编程:
常常使用此包下的类进行Android特有的网络编程,如:访问WiFi,访问Android联网信息,邮件等功能。

这里就不详细做例子了,因为这个接触比较多~~~。

 

 

如果上面的代码不能运行,就看看我这篇文章吧:http://my.oschina.net/yaowen424/blog/528542

© 著作权归作者所有

茗香墨语
粉丝 10
博文 41
码字总数 27952
作品 0
广州
程序员
私信 提问
加载中

评论(20)

茗香墨语
茗香墨语 博主

引用来自“12叔”的评论

HttpClient 6.0 以后已移除不建议使用
用更安全的咯,又不是说一定要用它
244576106
244576106
晕 这么浅陋的文章还推荐
茗香墨语
茗香墨语 博主

引用来自“jinhaoxia”的评论

lz介绍下第三种呗0
第三种用另外的博客说明,有时间就发~
mgic
mgic
建议首页放点更有深度的博文。
小编是不是吃错药了。
jinhaoxia
jinhaoxia
lz介绍下第三种呗0
茗香墨语
茗香墨语 博主

引用来自“rekka”的评论

httpclient android5.1就弃用了,还在这里例子写这个
弃用了还是可以用的啊,当然你也可以用httpurlconection代替咯
茗香墨语
茗香墨语 博主

引用来自“归丶海”的评论

网太卡 不小心提交了三次40
我提交了三次了吗???我不知道耶,可能是网络卡的问题啊
茗香墨语
茗香墨语 博主

引用来自“12叔”的评论

HttpClient 6.0 以后已移除不建议使用
即使被移除,但是还是可以使用的啊!我现在就是在用最新的版的api23做的!但是你也可以用httpurlconection来替换咯;
yanweimin7
yanweimin7

引用来自“滚地龙”的评论

应该说是常用的两种通讯协议吧,http和tcp
http 基于 tcp的。
rekka
rekka
httpclient android5.1就弃用了,还在这里例子写这个
移动端IM开发需要面对的技术问题

1、前言 这两年多一直从事网易云信 iOS 端 IM SDK的开发,期间不断有兄弟部门的同事和合作伙伴过来问各种技术细节,干脆统一介绍下一个IM APP的方方面面,包括技术选型(包括通讯方式,网络连...

JackJiang-
2016/08/09
236
0
如何选择即时通讯应用的数据传输格式

前言 即时通讯应用(包括IM聊天应用、实时消息推送应用等)开发的前期技术选型时,关于数据传输格式的选择,在即时通讯开发者同行的眼里,是个极富争议话题。 精略分析一下,大概的原因在于:...

JackJiang-
2016/08/04
560
1
新手入门一篇就够:从零开发移动端IM

一、前言 IM发展至今,已是非常重要的互联网应用形态之一,尤其移动互联网时代,它正以无与论比的优势降低了沟通成本和沟通代价,对各种应用形态产生了深远影响。 做为IM开发者或即将成为IM开...

JackJiang-
2016/08/03
877
4
Android中Intent组件详解

Intent是不同组件之间相互通讯的纽带,封装了不同组件之间通讯的条件。Intent 本身是定义为一个类别(Class),一个Intent对象表达一个目的(Goal)或期望(Expectation),叙述其所期望的服务或动...

Remix_jx
2014/10/16
4.5K
0
IM消息送达保证机制实现(二):保证离线消息的可靠投递

1、前言 本文的上篇《IM消息送达保证机制实现(一):保证在线实时消息的可靠投递》中,我们讨论了在线实时消息的投递可以通过应用层的确认、发送方的超时重传、接收方的去重等手段来保证业务层...

JackJiang-
2016/11/18
1K
0

没有更多内容

加载失败,请刷新页面

加载更多

分布式协调服务zookeeper

ps.本文为《从Paxos到Zookeeper 分布式一致性原理与实践》笔记之一 ZooKeeper ZooKeeper曾是Apache Hadoop的一个子项目,是一个典型的分布式数据一致性的解决方案,分布式应用程序可以基于它...

ls_cherish
今天
4
0
redis 学习2

网站 启动 服务端 启动redis 服务端 在redis 安装目录下 src 里面 ./redis-server & 可以指定 配置文件或者端口 客户端 在 redis 的安装目录里面的 src 里面 ./redis-cli 可以指定 指定 连接...

之渊
昨天
2
0
Spring boot 静态资源访问

0. 两个配置 spring.mvc.static-path-patternspring.resources.static-locations 1. application中需要先行的两个配置项 1.1 spring.mvc.static-path-pattern 这个配置项是告诉springboo......

moon888
昨天
4
0
hash slot(虚拟桶)

在分布式集群中,如何保证相同请求落到相同的机器上,并且后面的集群机器可以尽可能的均分请求,并且当扩容或down机的情况下能对原有集群影响最小。 round robin算法:是把数据mod后直接映射...

李朝强
昨天
4
0
Kafka 原理和实战

本文首发于 vivo互联网技术 微信公众号 https://mp.weixin.qq.com/s/bV8AhqAjQp4a_iXRfobkCQ 作者简介:郑志彬,毕业于华南理工大学计算机科学与技术(双语班)。先后从事过电子商务、开放平...

vivo互联网技术
昨天
24
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部