Android实现实时通信示例
姚高爽
本文向大家介绍Android实现实时通信示例，包括了Android实现实时通信示例的使用技巧和注意事项，需要的朋友参考一下
我们今天来聊下如何做实时通讯（先给知识点，实现原理，最后给出实现实时通信的具体代码--使用工具 android studio）
现在先说下用到的知识点：
- java的socket包括服务端和客户端, 这个是用来实现通信
- java的多线程,这个是用来实现实时通信
- java的线程通信,实现界面实时更新
实现原理
就是将发送端，接收端分别放进一个线程去运行，然后利用线程通信类handler来进行线程间的通信，实现界面的通信
实现代码：
权限
<uses-permission android:name="android.permission.ACCESS_WIFI_STATE"></uses-permission> <uses-permission android:name="android.permission.CHANGE_WIFI_STATE"></uses-permission> <uses-permission android:name="android.permission.WAKE_LOCK"></uses-permission> <uses-permission android:name="android.permission.INTERNET"/>
Layout
<?xml version="1.0" encoding="utf-8"?>
<LinearLayout xmlns:android="http://schemas.android.com/apk/res/android"
android:orientation="vertical"
xmlns:tools="http://schemas.android.com/tools"
android:id="@+id/activity_main"
android:layout_width="match_parent"
android:layout_height="match_parent"
tools:context="com.ysp.asus.experiment_02.MainActivity"
android:weightSum="10">
<Button
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="1"
android:background="#03A9F4"
android:textColor="#FFFFFFFF"
android:textSize="30sp"
android:text="IP"
android:id="@+id/myIP"/>
<!--点击开始聊天-->
<LinearLayout
android:orientation="horizontal"
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="1"
android:weightSum="10">
<!--IP-->
<EditText
android:layout_width="match_parent"
android:layout_height="match_parent"
android:layout_weight="1"
android:id="@+id/IP"
android:hint="请写入对方通讯地址IP"
/>
</LinearLayout>
<!--显示聊天记录-->
<EditText
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="7"
android:gravity="top"
android:editable="false"
android:scrollbars="vertical"
android:id="@+id/receiveMessage"/>
<!--用于写入发送信息和按钮-->
<LinearLayout
android:layout_width="match_parent"
android:layout_height="0dp"
android:layout_weight="1">
<EditText
android:layout_width="0dp"
android:layout_weight="8"
android:layout_height="match_parent"
android:hint="填写要发送的信息"
android:id="@+id/message"/>
<Button
android:layout_width="0dp"
android:layout_weight="2"
android:layout_height="match_parent"
android:text="发送消息"
android:background="#03A9F4"
android:textColor="#FFFFFFFF"
android:id="@+id/sendMessage"/>
</LinearLayout>
</LinearLayout>
客户端类
package com.ysp.asus.experiment_02;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.Socket;
import java.net.UnknownHostException;
/**
* Created by asus on 2017/3/16.
*/
public class ChatClient {
public Socket requestSocket(String host) throws UnknownHostException,IOException{
Socket socket=new Socket(host,5000);
return socket;
}
public void sendMsg(Socket socket,String msg)throws IOException{
BufferedWriter writer=new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())
);
writer.write(msg.replace("\n","")+"\n");
writer.flush();
}
public String receiveMsg(Socket socket)throws IOException{
BufferedReader reader=new BufferedReader(
new InputStreamReader(socket.getInputStream())
);
String txt=reader.readLine();
return txt;
}
}
服务端类
package com.ysp.asus.experiment_02;
import android.os.Handler;
import android.os.Message;
import android.util.Log;
import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStreamWriter;
import java.net.ServerSocket;
import java.net.Socket;
/**
* Created by asus on 2017/3/16.
*/
public class ChatServer extends Thread {
public ChatServer() throws IOException {
createSocket();
}
public void run(){
Socket client;
String txt;
Log.i("信息","成功开始服务器，端口为："+PORT);
try{
while (true){
client=ResponseSocket();
while(true){
txt=ReceiveMsg(client);
System.out.println(txt);
Message message1 = new Message();
message1.obj =txt+"\n";
com.ysp.asus.experiment_02.MainActivity.handler.sendMessage(message1);
if(true)
break;
}
// CloseSocket(client);
}
}catch (IOException e){
}
}
private Handler mHandler = new Handler(){
public void handleMessage(Message msg) {
};
};
public ServerSocket server=null;
private int PORT =5000;
private BufferedWriter writer;
private BufferedReader reader;
public void createSocket() throws IOException{
server=new ServerSocket(PORT,100);
}
public Socket ResponseSocket() throws IOException{
Socket client =server.accept();
return client;
}
public void CloseSocket(Socket socket) throws IOException{
reader.close();
socket.close();
server.close();
}
public void sendMsg(Socket socket,String string)throws IOException{
writer=new BufferedWriter(
new OutputStreamWriter(socket.getOutputStream())
);
writer.write("msg"+string);
writer.flush();
}
public String ReceiveMsg(Socket socket) throws IOException{
reader=new BufferedReader(
new InputStreamReader(socket.getInputStream())
);
String txt ="对方:"+reader.readLine();
return txt;
}
}
MainActivity类
package com.ysp.asus.experiment_02;
import android.content.Context;
import android.net.wifi.WifiInfo;
import android.net.wifi.WifiManager;
import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.text.ClipboardManager;
import android.util.Log;
import android.view.View;
import android.view.inputmethod.InputMethodManager;
import android.widget.Button;
import android.widget.EditText;
import java.io.IOException;
import java.net.Socket;
import static com.ysp.asus.experiment_02.R.id.receiveMessage;
public class MainActivity extends AppCompatActivity {
final ChatServer chatServer=null;
static String text="";
static EditText receivemessage=null;
final ChatClient chatClient = new ChatClient();
@Override
protected void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
// 定义相关的变量
receivemessage=(EditText) findViewById(receiveMessage);
final EditText message=(EditText)findViewById(R.id.message);
final EditText IP = (EditText)findViewById(R.id.IP);
final Button sendmessage = (Button)findViewById(R.id.sendMessage);
final Button myIP =(Button) findViewById(R.id.myIP);
// 获取wifi下的IP地址并显示
//获取wifi服务
WifiManager wifiManager = (WifiManager) getSystemService(Context.WIFI_SERVICE);
//判断wifi是否开启
if (!wifiManager.isWifiEnabled()) {
wifiManager.setWifiEnabled(true);
}
WifiInfo wifiInfo = wifiManager.getConnectionInfo();
int ipAddress = wifiInfo.getIpAddress();
String ip = intToIp(ipAddress);
myIP.setText(ip);
// 点击实现复制内容到粘贴板
myIP.setClickable(true);
myIP.setOnClickListener(new Button.OnClickListener() {
public void onClick(View arg0) {
ClipboardManager cm = (ClipboardManager) getSystemService(Context.CLIPBOARD_SERVICE);
// 将文本内容放到系统剪贴板里。
cm.setText(myIP.getText().toString());
}
});
// 初始化看是服务器
try{
ChatServer chatServer=new ChatServer();
chatServer.start();
}catch(IOException e){
Log.e("错误","开启服务器失败");
e.printStackTrace();
}
// 点击按钮发送数据给相应的IP地址
sendmessage.setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View v) {
HideKeyboard(sendmessage);
new Thread(new Runnable() {
@Override
public void run() {
try {
Socket socket=chatClient.requestSocket(IP.getText().toString());
chatClient.sendMsg(socket,message.getText().toString());
Message message1 = new Message();
message1.obj ="自己： "+message.getText().toString()+"\n";
handler.sendMessage(message1);
}catch (IOException e){
Log.e("错误","发送失败");
}
}
}).start();
}
});
}
public static Handler handler=new Handler(){
@Override
public void handleMessage(Message msg) {
super.handleMessage(msg);
Log.i("信息","其他线程发过来："+msg);
text+=msg.obj.toString();
receivemessage.setText(text);
receivemessage.setSelection(receivemessage.getText().length(), receivemessage.getText().length());
}
};
// 用于将结果以IP的形式放出
private String intToIp(int i) {
return (i & 0xFF ) + "." +
((i >> 8 ) & 0xFF) + "." +
((i >> 16 ) & 0xFF) + "." +
( i >> 24 & 0xFF) ;
}
//隐藏虚拟键盘
public static void HideKeyboard(View v)
{
InputMethodManager imm = ( InputMethodManager ) v.getContext( ).getSystemService( Context.INPUT_METHOD_SERVICE );
if ( imm.isActive( ) ) {
imm.hideSoftInputFromWindow( v.getApplicationWindowToken( ) , 0 );
}
}
}
效果展示
demo示例下载：http://pan.baidu.com/s/1hr2OiZq
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持小牛知识库。
类似资料：
-
本文向大家介绍Android编程实现定时发短信功能示例，包括了Android编程实现定时发短信功能示例的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了Android编程实现定时发短信功能。分享给大家供大家参考，具体如下： 第一，要实现发短信的功能，必须要用到android系统中发短信的权限，即在AndoridManifest.xml中添加如下内容 第二，使用AlarmManager来实现一
-
本文向大家介绍Java 实现简单Socket 通信的示例，包括了Java 实现简单Socket 通信的示例的使用技巧和注意事项，需要的朋友参考一下 Java socket 封装了传输层的实现细节，开发人员可以基于 socket 实现应用层。本文介绍了 Java socket 简单用法。 1. 传输层协议 传输层包含了两种协议，分别是 TCP (Transmission Control Protoc
-
本文向大家介绍Python实现TCP通信的示例代码，包括了Python实现TCP通信的示例代码的使用技巧和注意事项，需要的朋友参考一下 使用socket实现tcp通信，需导入socket模块 1、服务端 主要步骤： （1）创建socket：socket.socket(family=AF_INET, type=SOCK_STREAM, proto=0, fileno=None) family：AF_
-
本文向大家介绍Android编程实现TCP、UDP客户端通信功能示例，包括了Android编程实现TCP、UDP客户端通信功能示例的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了Android编程实现TCP、UDP客户端通信功能。分享给大家供大家参考，具体如下： 在进行Android开发的过程中，免不了，要开发TCP/UDP通讯的程序，下面这两段代码，分别介绍了TCP/UCP通过的一个实例
-
本文向大家介绍python3利用Socket实现通信的方法示例，包括了python3利用Socket实现通信的方法示例的使用技巧和注意事项，需要的朋友参考一下 参考于： python cs架构实现简单文件传输 原文中程序运行有误，在此做修改与解释，如下： 功能说明： 共2个py文件分别为server和client端，采用socket进行通信。提供两种功能：“dir“ 命令用于显示服务器端可下载文件
-
本文向大家介绍Python socket实现的简单通信功能示例，包括了Python socket实现的简单通信功能示例的使用技巧和注意事项，需要的朋友参考一下 本文实例讲述了Python socket实现的简单通信功能。分享给大家供大家参考，具体如下： 套接字(socket)是计算机网络数据结构，在任何类型的通信开始之前，网络应用程序必须创建套接字，可以将其比作电话的插孔，没有它将无法进行通信 常