第1页 / 共15页
第2页 / 共15页
第3页 / 共15页
第4页 / 共15页
第5页 / 共15页
第6页 / 共15页
第7页 / 共15页
第8页 / 共15页
Android Socket接口实现即时通讯实例代码.pdf
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 工具集由三种基本节组成，这三种节分别为、出席、。XMPP 流由两份 XML 文
档组成，通信的每个方向均有一份文档。这份文档有一个根元素，这个根元素的子元素由可路由的节以及与
流相关的顶级子元素构成。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);
}
}
/**
* Created by huang on 2016/12/3.
* 消息类型
*/
public class QQmessageType {
public static final String MSG_TYPE_REGISTER = "register";// 注册
public static final String MSG_TYPE_LOGIN = "login";// 登录
public static final String MSG_TYPE_LOGIN_OUT = "loginout";// 登出
public static final String MSG_TYPE_CHAT_P2P = "chatp2p";// 聊天
public static final String MSG_TYPE_CHAT_ROOM = "chatroom";// 群聊
public static final String MSG_TYPE_OFFLINE = "offline";// 下线
public static final String MSG_TYPE_SUCCESS = "success";//成功
public static final String MSG_TYPE_BUDDY_LIST = "buddylist";// 好友
public static final String MSG_TYPE_FAILURE = "failure";// 失败
}
import com.example.huang.imsocket.bean.ProtacolObjc;
/*
*消息本身 包括 账号、头像和昵称
*
*/
public class QQBuddy extends ProtacolObjc {
public long account;
public String nick;
public int avatar;
}
/**
* Created by huang on 2016/12/3.
*/
public class QQBuddyList extends ProtacolObjc {
public ArrayList buddyList = new ArrayList<>();
}
关于socket的创建连接和发送消息、接受消息。
import android.util.Log;
import com.example.huang.imsocket.bean.QQMessage;
import java.io.DataInputStream;
import java.io.DataOutputStream;
import java.io.IOException;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
/**
* Created by huang on 2016/12/3.
* 连接 服务器
*/
public class QQConnection extends Thread {
private static final String TAG = "QQConnection";
private Socket client;
private DataOutputStream write;
private DataInputStream read;
public static final String HOST = "192.168.23.48";
public static final int POST = 5225;
private boolean flag = true;
private List mOnQQmwssagereceiveLisener = new ArrayList<>();
public void addOnQQmwssagereceiveLisener(OnQQmwssagereceiveLisener lisener) {
mOnQQmwssagereceiveLisener.add(lisener);
}
public void removeOnQQmwssagereceiveLisener(OnQQmwssagereceiveLisener lisener) {
mOnQQmwssagereceiveLisener.remove(lisener);
}
public interface OnQQmwssagereceiveLisener {
public void onReiceive(QQMessage qq);
}
@Override
public void run() {
super.run();
while (flag) {
try {
String utf = read.readUTF();
QQMessage message = new QQMessage();
QQMessage msg = (QQMessage) message.fromXml(utf);
if (msg != null) {
for (OnQQmwssagereceiveLisener lisner : mOnQQmwssagereceiveLisener)
lisner.onReiceive(msg);
}
} catch (IOException e) {
e.printStackTrace();
}
}
}
public void connect() {
try {
if (client == null) {
client = new Socket(HOST, POST);
write = new DataOutputStream(client.getOutputStream());
read = new DataInputStream(client.getInputStream());
flag = true;
this.start();
Log.e(TAG, "connect: "+(write==null)+"---"+ (read == null));
}
} catch (Exception e) {
e.printStackTrace();
}
}
public void disconnect() {
if (client != null) {
flag = false;
this.stop();
try {
read.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
write.close();
} catch (IOException e) {
e.printStackTrace();
}
try {
client.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
public void send(String xml) throws IOException {
write.writeUTF(xml);
write.flush();
}
public void send(QQMessage qq) throws IOException {
write.writeUTF(qq.toXml());
write.flush();
}
}
闪屏界面的布局
闪屏界面，保持4秒钟进入登陆界面。一般来见，闪屏界面可以加载数据、获取版本号、更新版本等操作。这里没有
做的那么复杂。
import com.example.huang.imsocket.R;
public class SplashActivity extends AppCompatActivity {
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
getSupportActionBar().hide(); //隐藏标栏
getWindow().setFlags(WindowManager.LayoutParams.FLAG_FULLSCREEN,
WindowManager.LayoutParams.FLAG_FULLSCREEN); //全屏显示
setContentView(R.layout.activity_splash);
new Handler().postDelayed(new Runnable() {
@Override
public void run() {
startActivity(new Intent(SplashActivity.this, LoginActivity.class));
finish();
}
}, 4000);
}
}
登陆界面的布局
import com.example.huang.imsocket.core.QQConnection;
import com.example.huang.imsocket.service.IMService;
import com.example.huang.imsocket.util.ThreadUtils;
import java.io.IOException;
/**
* Created by huang on 2016/12/3.
*/
public class LoginActivity extends Activity {
private static final String TAG = "LoginActivity";
private EditText et_accoun;
private EditText et_pwd;
private String accoun;
private QQConnection conn;
private QQConnection.OnQQmwssagereceiveLisener lisener = new QQConnection.OnQQmwssagereceiveLisener() {
@Override
public void onReiceive(final QQMessage qq) {
final QQBuddyList list = new QQBuddyList();
final QQBuddyList list2 = (QQBuddyList) list.fromXml(qq.content);
if (QQmessageType.MSG_TYPE_BUDDY_LIST.equals(qq.type)) {
ThreadUtils.runUIThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getBaseContext(), "成功", Toast.LENGTH_SHORT).show();
Myapp.me = conn;
Myapp.username = accoun;
Myapp.account = accoun + "@qq.com";
Intent intent = new Intent(LoginActivity.this, contactActivity.class);
intent.putExtra("list", list2);
startActivity(intent);
Intent data = new Intent(LoginActivity.this, IMService.class);
startService(data);
finish();
}
});
} else {
ThreadUtils.runUIThread(new Runnable() {
@Override
public void run() {
Toast.makeText(getBaseContext(), "登陆失败", Toast.LENGTH_SHORT).show();
}
});
}
}
};
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_login);
et_accoun = (EditText) findViewById(R.id.et_accoun);
et_pwd = (EditText) findViewById(R.id.et_pwd);
ThreadUtils.runINThread(new Runnable() {
@Override
public void run() {
try {
conn = new QQConnection();
conn.addOnQQmwssagereceiveLisener(lisener);
conn.connect();
} catch (Exception e) {
e.printStackTrace();
}
}
});
}
public void sendmessage(View view) {
accoun = et_accoun.getText().toString().trim();
final String password = et_pwd.getText().toString().trim();
Log.i(TAG, "sendmessage: " + accoun + "#" + password);
ThreadUtils.runINThread(new Runnable() {
@Override
public void run() {
QQMessage message = new QQMessage();
message.type = QQmessageType.MSG_TYPE_LOGIN;
message.content = accoun + "#" + password;
String xml = message.toXml();
if (conn != null) {
try {
conn.send(xml);
} catch (IOException e) {
e.printStackTrace();
}
}
}
});
}
@Override
protected void onDestroy() {
super.onDestroy();
conn.removeOnQQmwssagereceiveLisener(lisener);
}
}
好友列表界面
好友列表及时收到从哪个服务其发挥的好友更新信息，点击条目跳到聊天界面。
import android.app.Activity;
import android.content.Intent;
import android.graphics.Color;
import android.os.Bundle;
import android.view.View;
import android.view.ViewGroup;
import android.widget.AdapterView;
import android.widget.ArrayAdapter;
import android.widget.ImageView;
import android.widget.ListView;
import android.widget.TextView;
import android.widget.Toast;
相关推荐
2023年江西萍乡中考道德与法治真题及答案.doc
2012年重庆南川中考生物真题及答案.doc
2013年江西师范大学地理学综合及文艺理论基础考研真题.doc
2020年四川甘孜小升初语文真题及答案I卷.doc
2020年注册岩土工程师专业基础考试真题及答案.doc
2023-2024学年福建省厦门市九年级上学期数学月考试题及答案.doc
2021-2022学年辽宁省沈阳市大东区九年级上学期语文期末试题及答案.doc
2022-2023学年北京东城区初三第一学期物理期末试卷及答案.doc
2018上半年江西教师资格初中地理学科知识与教学能力真题及答案.doc
2012年河北国家公务员申论考试真题及答案-省级.doc
2020-2021学年江苏省扬州市江都区邵樊片九年级上学期数学第一次质量检测试题及答案.doc
2022下半年黑龙江教师资格证中学综合素质真题及答案.doc
