AndroidSocket接口实现即时通讯实例代码资源-CSDN文库

156 浏览量 2021-01-20 09:39:54 上传评论收藏 131KB PDF 举报

身份认证购VIP最低享 7 折!

领优惠券(最高得80元）

资源详情

资源评论

资源推荐

Android Socket接口实现即时通讯实例代码接口实现即时通讯实例代码

Android Socket接口实现即时通讯接口实现即时通讯

最近学习Android 通信的知识，做一个小实例，巩固下学习内容，以下内容是网上找的资料，觉得很不错，知识比较

全面，大家看下。

首先了解一下即时通信的概念。通过消息通道传输消息对象,一个账号发往另外一账号，只要账号在线，可以即时获取到消

息，这就是最简单的即使通讯。消息通道可由TCP/IP UDP实现。通俗讲就是把一个人要发送给另外一个人的消息对象（文

字，音视频，文件）通过消息通道(C/S实时通信)进行传输的服务。即时通讯应该包括四种形式，在线直传、在线代理、离线

代理、离线扩展。在线直传指不经过服务器，直接实现点对点传输。在线代理指消息经过服务器，在服务器实现中转，最后到

达目标账号。离线代理指消息经过服务器中转到达目标账号，对方不在线时消息暂存服务器的数据库,在其上线再传发。离线

扩展指将暂存消息以其它形式，例如邮件、短信等转发给目标账号。

此外，我们还需要认识一下计算机网络相关的概念。经典的计算机网络四层模型中，TCP和UDP是传输层协议，包含着

消息通信内容。ip为网络层协议，是一种网络地址。TCP/IP，即传输控制协议/网间协议，定义了主机如何连入因特网及数据

如何在它们之间传输的标准。Socket，又称“套接字”，在应用层和传输层之间的一个抽象层，用于描述 IP 地址和端口，是一

个通信连的句柄，应用程序通常通过“套接字”向网络发送请求或者应答网络请求，它就是网络通信过程中端点的抽象表示。它

把TCP/IP层复杂的操作抽象为几个简单的接口供应用层调用已实现进程在网络中通信。XMPP（可扩展消息处理现场协议）

是基于可扩展标记语言（XML）的协议，应用于即时通讯场景的应用层协议，底层通过Socket实现。它用于即时消息（IM）

以及在线现场探测。它在促进服务器之间的准即时操作。这个协议可能最终允许因特网用户向因特网上的其他任何人发送即时

消息，即使其操作系统和浏览器不同。这样实现即时通讯就有两种方案，一是从套接字入手，直接利用socket提供的接口进

行数据的传送。二是借助开源工具(服务器openfire)，用XMPPConnection创建连接。

XMPP是实现即时通讯使用较为普遍的做法。XMPP中，各项工作都是通过在一个 XMPP 流上发送和接收 XMPP 节来完成

的。核心 XMPP 工具集由三种基本节组成，这三种节分别为<presence>、出席<message>、<iq>。XMPP 流由两份 XML 文

档组成，通信的每个方向均有一份文档。这份文档有一个根元素<stream:stream>，这个根元素的子元素由可路由的节以及与

流相关的顶级子元素构成。xmpp协议同样包括客户端和服务器。客户端基于 Android 平台进行开发。负责初始化通信过程，

进行即时通信时，由客户端负责向服务器发起创建连接请求。系统通过 GPRS 无线网络与Internet 网络建立连接，通过服务器

实现与 Android 客户端的即时通信脚。服务器端则采用 Openfire 作为服务器。允许多个客户端同时登录并且并发的连接到一

个服务器上。服务器对每个客户端的连接进行认证，对认证通过的客户端创建会话，客户端与服务器端之间的通信就在该会话

的上下文中进行。使用了 asmark 开源框架实现的即时通讯功能.该框架基于开源的 XMPP 即时通信协议，采用 C／S 体系结

构，通过 GPRS 无线网络用TCP 协议连接到服务器，以架设开源的 Openfn’e 服务器作为即时通讯平台。xmpp消息通道的创

建：

先配置通道信息进行连接

ConnectionConfiguration configuration = new ConnectionConfiguration(HOST, PORT)，

设置Debug信息和安全模式

configuration.setDebuggerEnabled(true);

configuration.setSecurityMode(SecurityMode.disabled)，

最后才是建立连接

conn.connect();

在ContentObserver的实现类中观察消息变化。XMPPConnection.getRoster()获取联系人列表对象。用xmpp协议编写通

讯协议的大致思路可以如下。进入登陆界面，通过xmppconnection的login方法实现登陆，登陆成功进入主界面。主界面包含

两个Fragment,分别用来显示联系人和聊天记录。创建联系人和短信的数据观察者，在联系人、短信服务中分别设定监听

RosterListener()、ChatManagerListener()，接受联系人和短信信息，同时将相关信息添加到内容提供者中。在内容提供者中

设定一个内容观察者，当数据发生变化时通知界面更新。

本文的重点是利用Socket的接口实现即时通讯，因为绝大多数即时通讯的底层都是通过Socket实现的。其基本的业务逻

辑可描述如下。用户进入登陆界面后，提交账号密码经服务端确定，返回相关参数用于确定连接成功。进入聊天界面或好友

界面。点击联系人或聊天记录的条目，进入聊天界面。当移动端再次向服务器发送消息时，由服务器转发消息内容给目标账

号。同时更新界面显示。这样就完成即时通讯的基本功能。当然，也可以添加一个后台服务，当用户推出程序时，在后台接受

消息。不难看出，对于即时通讯来讲，有三个关注点：消息通道、消息内容、消息对象。因此，主要逻辑也是围绕这三个点展

开。消息通道实现传输消息对象的发送和接收。为Socket(String host, int port)传入服务其地址和端口号，即可创建连接。消

息内容的格式应该与服务器保持一致。接受数据时，获取输入流并用DataInputStream包装，通过输入流读取server发来的数

据。发送数据时，获取输出流并用DataOutputStream包装，通过输出流往server发送数据。消息内容中应该包括发送者、接

受者信息、数据类型等。消息对象就是消息的发送者和消息的接受者。接下来在代码中进行详细的讲解。

创建一个消息的基类，实现xml文件和字符串的转换，用到Xsream第三方jar包。这样当创建消息类时，继承该方法，就

可以直接在类中实现数据的转换。

/**

* Created by huang on 2016/12/3.

public class ProtacolObjc implements Serializable {

public String toXml() {

XStream stream = new XStream();

//将根节点转换为类名

stream.alias(this.getClass().getSimpleName(), this.getClass());

return stream.toXML(this);

}

public Object fromXml(String xml) {

XStream x = new XStream();

x.alias(this.getClass().getSimpleName(), this.getClass());

return x.fromXML(xml);

}

//创建Gson数据和字符串之间转换的方法，适应多种数据

public String toGson() {

Gson gson = new Gson();

return toGson();

}

public Object fromGson(String result) {

Gson gson = new Gson();

return gson.fromJson(result, this.getClass());

}

创建线程工具，指定方法运行在子线程和主线程中。由于网络操作需要在子线程中，界面更新需要在主线程中，创建线

程工具可以方便选择线程。

import android.os.Handler;

/**

* Created by huang on 2016/12/5.

public class ThreadUtils {

private static Handler handler = new Handler();

public static void runUIThread(Runnable r){

handler.post(r);

}

public static void runINThread(Runnable r){

new Thread(r).start();

}

创建消息的工具类，包括消息内容、消息类型、消息本省等。由于服务器返回的内容中包含消息的包名信息所以消息本

身的包名应该于服务其保持一直。

/**

* Created by huang on 2016/12/3.

* 消息内容

public class QQMessage extends ProtacolObjc {

public String type = QQmessageType.MSG_TYPE_CHAT_P2P;// 类型的数据 chat login

public long from = 0;// 发送者 account

public String fromNick = "";// 昵称

public int fromAvatar = 1;// 头像

public long to = 0; // 接收者 account

public String content = ""; // 消息的内容约不?

public String sendTime = getTime(); // 发送时间

public String getTime() {

Date date = new Date(System.currentTimeMillis());

java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("mm-DD HH:mm:ss");

return format.format(date);

}

public String getTime(Long time) {

Date date = new Date(time);

java.text.SimpleDateFormat format = new java.text.SimpleDateFormat("mm-DD HH:mm:ss");

return format.format(date);

}

剩余14页未读，继续阅读

评论收藏

内容反馈

weixin_38629042

粉丝: 5
资源: 930

会员权益专享

Android Socket接口实现即时通讯实例代码

评论0

会员权益专享

最新资源

Android Socket接口实现即时通讯实例代码

评论0

Android开发之Socket通信传输简单示例

dyad:点对点安卓通信

Android应用源码安卓源码包wifi蓝牙串口&Socket通讯窗口抖动Widget小组件等20个合集.zip

JAVA上百实例源码以及开源项目源代码

JAVA上百实例源码以及开源项目

Google Android SDK开发范例大全(第3版) 1/5

Google Android SDK开发范例大全(第3版) 4/5

Google Android SDK开发范例大全(第3版) 3/5

Google Android SDK开发范例大全(第3版) 5/5

加速度积分求速度和位移的c语言算法程序

数据结构课设用C、C++写旅游区景点导游系统头文件(用文件存储，DFS，DIJ算法），完全免费！没有要积分，能多给我点点赞吗？

DeepLearning之LSTM模型输入参数：time_step, input_size, batch_size的理解

ISO14229-1中文

Vulkan编程指南.pdf

python自动化办公——python操作Excel、Word、PDF集合大全

数据结构课设用C、C++写旅游区景点导游系统函数文件(用文件存储，DFS，DIJ算法），完全免费！没有要积分，能多给我点点赞吗？

C#40000字全套精华教程！！！从入门到精通，一篇就够了！！！

数据结构课设用C、C++写旅游区景点导游系统main函数(使用文件存储，DFS，DIJ算法，附详细说明）完全免费，求求点赞！

Qt移植：Ubuntu18.04 交叉编译qt5.12.7详细教程配置编译qt-everywhere-src-5.12.7

数据特征分析：相关性分析（Pandas中的corr方法）

C++数据结构课程设计大作业-员工管理系统(带完整报告）

基于stm32水质监测系统（毕设）

Cmake从入门到精通（pdf教程）

基于51单片机的温控系统

modbus tcp/rtu客户端服务端通讯程序合集（C#、c++、mfc）

CEC2021基础测试函数(matlab和C两个版本)

解决 github项目clone报错 Failed connect to github.com:443; Connection

会员权益专享

最新资源