android socket聊天室功能实现

前提概要

笔者很久之前其实就已经学习过了socket，当然也是用socket做过了聊天室，但是觉得此知识点比较一般，并无特别难的技术点，于是也并未深究。
然而近期一个项目中对socket的使用却让笔者感觉socket强大无比，可以实现诸多功能。

个人Socket体验

项目主要有关智能家居，需要实现多台手机同时对灯进行操作（开或者关），主要需要实现以下几点：

1、进入界面时获取所有灯的状态。
2、一台手机改变了灯的状态，其他的手机上可以有所显示。
3、硬件上改变了灯的状态（手动开关灯），所有手机上要有所显示。

此功能如果使用HTTP读取的方式实现就不太合适了。一方面客户端与服务器读取文件的同步性难以保证，即使保证了，也需要浪费大量性能；另一方面，类似笔者的这种项目功能服务器和客户端交互比较频繁，对“即时性”要求也比较高，用HTTP不仅性能消耗太大，而且难以保证“即时性”。

但是使用Socket就很容易实现了，主要逻辑如下：

1、每次进入界面与服务器建立Socket连接，并得到此时灯的状态
2、每次需要对灯进行操作的时候建立一个线程把灯的状态传递给服务器，服务器接收到之后，把该状态传递给每一个此时与服务器建立连接的客户端。

此次体验也是让笔者想起了学长之前做的一道笔试题，题目大概如下：

将淘宝网页和手机版同时打开账户，手机停留在购物车界面，此时网页上将某一物品加入购物车，如何设计才能让手机自动刷新购物车。

如果使用socket，相信是一个不错的思路。

好了，接下来进入正题，展示socket聊天室demo。

效果（源码在文章结尾）

主要思路

Android

1、进入界面客户端与服务器建立socket，同时此时开启一个线程一直接收服务器发送来的消息。
2、每次点击button获取EditText中的字符串，调用子线程把字符串发送给服务器。

服务器

1、创建一个ArrayList存储Socket。
2、循环接收请求访问该端口的客户端，接收到之后，把该socket存储到ArrayList中，并且为每一个socket开启一个线程用于通信。
3、每个socket的线程的逻辑如下：循环接收客户端发来的消息，接收到之后，利用之前的ArrayList，发送到每一个客户端。如果某个客户端返回空值或者无法发送过去，那么表示该客户端已经断开，就从ArrayList中移除。

代码

（借鉴《Android疯狂讲义》）

Android

不要忘记在AndroidManifest里面加上访问网络的权限

MainActivity:

package com.example.double2.sockettesttwo;

import android.os.Bundle;
import android.os.Handler;
import android.os.Message;
import android.support.v7.app.AppCompatActivity;
import android.view.View;
import android.widget.Button;
import android.widget.EditText;
import android.widget.TextView;

public class MainActivity extends AppCompatActivity {

 private EditText etMain;
 private Button btnMain;
 private TextView tvMain;
 private ClientThread mClientThread;

 //在主线程中定义Handler传入子线程用于更新TextView
 private Handler mHandler;

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

 etMain = (EditText) findViewById(R.id.et_main);
 btnMain = (Button) findViewById(R.id.btn_main);
 tvMain = (TextView) findViewById(R.id.tv_main);

 mHandler=new Handler() {
  @Override
  public void handleMessage(Message msg) {
  if (msg.what == 0) {
   tvMain.append("\n" + msg.obj.toString());
  }
  }
 };

 //点击button时，获取EditText中string并且调用子线程的Handler发送到服务器
 btnMain.setOnClickListener(new View.OnClickListener() {
  @Override
  public void onClick(View v) {
  try {
   Message msg = new Message();
   msg.what = 1;
   msg.obj = etMain.getText().toString();
   mClientThread.revHandler.sendMessage(msg);
   etMain.setText("");
  } catch (Exception e) {
   e.printStackTrace();
  }
  }
 });


 mClientThread = new ClientThread(mHandler);
 new Thread(mClientThread).start();


 }
}

ClientThread

package com.example.double2.sockettesttwo;

import android.os.Handler;
import android.os.Looper;
import android.os.Message;
import android.util.Log;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.Socket;

/**
 * 项目名称：SocketTestTwo
 * 创建人：Double2号
 * 创建时间：2016.11.20 9:16
 * 修改备注：
 */
public class ClientThread implements Runnable {
 private Socket mSocket;
 private BufferedReader mBufferedReader = null;
 private OutputStream mOutputStream = null;
 private Handler mHandler;

 public Handler revHandler;

 public ClientThread(Handler handler) {
 mHandler = handler;
 }

 @Override
 public void run() {
 try {
  mSocket = new Socket("10.3.20.159", 30003);
  Log.d("xjj","connect success");
  mBufferedReader = new BufferedReader(new InputStreamReader(mSocket.getInputStream()));
  mOutputStream = mSocket.getOutputStream();

  new Thread(){
  @Override
  public void run() {
   super.run();
   try {
   String content = null;
   while ((content = mBufferedReader.readLine()) != null) {
    Log.d("xjj",content);
    Message msg = new Message();
    msg.what = 0;
    msg.obj = content;
    mHandler.sendMessage(msg);
   }
   }catch (IOException e){
   e.printStackTrace();
   }
  }
  }.start();

  //由于子线程中没有默认初始化Looper，要在子线程中创建Handler，需要自己写
  Looper.prepare();
  revHandler = new Handler() {
  @Override
  public void handleMessage(Message msg) {
   if (msg.what == 1) {
   try {
    mOutputStream.write((msg.obj.toString() + "\r\n").getBytes("utf-8"));
   } catch (IOException e) {
    e.printStackTrace();
   }
   }
  }
  };
  Looper.loop();



 } catch (IOException e) {
  e.printStackTrace();
  Log.d("xjj","");
 }
 }
}

activity_main

<?xml version="1.0" encoding="utf-8"?>
<LinearLayout
 xmlns:android="http://schemas.android.com/apk/res/android"
 android:id="@+id/activity_main"
 android:layout_width="match_parent"
 android:layout_height="match_parent"
 android:padding="@dimen/activity_vertical_margin"
 android:orientation="vertical"
 >

 <LinearLayout
 android:layout_width="match_parent"
 android:layout_height="wrap_content"
 android:orientation="horizontal">

 <EditText
  android:id="@+id/et_main"
  android:layout_width="0dp"
  android:layout_height="wrap_content"
  android:layout_weight="1"/>

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

 <TextView
 android:id="@+id/tv_main"
 android:layout_width="match_parent"
 android:layout_height="match_parent"
 />
</LinearLayout>

服务器：

MySever

import java.io.IOException;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.ArrayList;

public class MySever {

 public static ArrayList<Socket> socketList = new ArrayList<Socket>();
 public static String content="";

 public static void main(String[] args) throws IOException {
 //建立ServerSocket
 ServerSocket ss = new ServerSocket(30003);

 //不断接收此端口的socket，并存储到socketList中
 //并且为每一个socket开启一个线程，用于接收信息
 while (true) {
  Socket s = ss.accept();
  System.out.println("connect success!");
  socketList.add(s);

  new Thread(new ServerThread(s)).start();
 }
 }

}

SeverThread

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.io.UnsupportedEncodingException;
import java.net.Socket;
import java.net.SocketException;
import java.util.Iterator;

public class ServerThread implements Runnable {

 private Socket mSocket = null;
 private BufferedReader mBufferedReader = null;

 // 构造函数中接收socket并且初始化BufferedReader
 public ServerThread(Socket socket) 
  throws UnsupportedEncodingException, IOException {
 mSocket = socket;
 mBufferedReader = new BufferedReader(
  new InputStreamReader(mSocket.getInputStream(), "utf-8"));
 }

 @Override
 public void run() {
 // TODO Auto-generated method stub

 try {
  String content = null;

  //循环接收来自此客户端的消息
  //如果接收不到了，表面已经断开，就将此客户端从socketList中移除
  while ((content = mBufferedReader.readLine()) != null) {

  System.out.println(content);

  //向连接中的每个客户端发送数据
  //如果异常，说明断开，就将该条目从socketList中移除
  for (Iterator<Socket> it = MySever.socketList.iterator(); 
   it.hasNext();) {
   Socket s = it.next();
   try {
   OutputStream os = s.getOutputStream();
   os.write((content + "\n").getBytes("utf-8"));
   } catch (SocketException e) {
   e.printStackTrace();
   it.remove();
   }
  }
  }
 } catch (IOException e) {
  e.printStackTrace();
  MySever.socketList.remove(mSocket);
 }
 }

}

源码地址：android socket聊天室

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

# android  # socket  # 聊天室  # Android Socket实现多个客户端聊天布局  # android使用Socket通信实现多人聊天应用  # Android Socket通信实现简单聊天室  # Android使用Websocket实现聊天室  # 基于Socket.IO实现Android聊天功能代码示例  # android Socket实现简单聊天小程序  # android Socket实现简单聊天功能以及文件传输  # Android 基于Socket的聊天室实例  # Android基于socket实现的简单C/S聊天通信功能  # Android Socket实现多个客户端即时通信聊天  # 客户端  # 购物车  # 移除  # 过了  # 发送到  # 把该  # 是一个  # 改变了  # 好了  # 不太  # 其他的  # 很久  # 较高  # 一台  # 要在  # 很容易  # 太大  # 能让  # 几点 

相关文章： 如何高效完成自助建站业务培训？  建站主机与服务器功能差异如何区分？  已有域名如何快速搭建专属网站？  建站之星好吗？新手能否轻松上手建站？  如何选择高效便捷的WAP商城建站系统？  c# 在高并发下使用反射发射（Reflection.Emit）的性能  c++怎么编写动态链接库dll_c++ __declspec(dllexport)导出与调用【方法】  怎么将XML数据可视化 D3.js加载XML  成都响应式网站开发,dw怎么把手机适应页面变成网页？  如何自己制作一个网站链接,如何制作一个企业网站，建设网站的基本步骤有哪些？  子杰智能建站系统｜零代码开发与AI生成SEO优化指南  建站主机服务器选购指南：轻量应用与VPS配置解析  手机网站制作平台,手机靓号代理商怎么制作属于自己的手机靓号网站？  安云自助建站系统如何快速提升SEO排名？  网站制作费用多少钱,一个网站的运营，需要哪些费用？  详解一款开源免费的.NET文档操作组件DocX（.NET组件介绍之一）  济南企业网站制作公司,济南社保单位网上缴费步骤？  建站主机选哪种环境更利于SEO优化？  如何在VPS电脑上快速搭建网站？  如何在万网主机上快速搭建网站？  javascript中对象的定义、使用以及对象和原型链操作小结  常州自助建站工具推荐：低成本搭建与模板选择技巧  定制建站流程步骤详解：一站式方案设计与开发指南  简历在线制作网站免费,免费下载个人简历的网站是哪些？  GML (Geography Markup Language)是什么，它如何用XML来表示地理空间信息？  定制建站哪家更专业可靠？推荐榜单揭晓  家族网站制作贴纸教程视频,用豆子做粘帖画怎么制作？  如何用y主机助手快速搭建网站？  制作ppt免费网站有哪些,有哪些比较好的ppt模板下载网站？  浙江网站制作公司有哪些,浙江栢塑信息技术有限公司定制网站做的怎么样？  教程网站设计制作软件,怎么创建自己的一个网站？  建站之星如何助力企业快速打造五合一网站？  个人网站制作流程图片大全,个人网站如何注销？  存储型VPS适合搭建中小型网站吗？  建站之星代理平台如何选择最佳方案？  如何在新浪SAE免费搭建个人博客？  制作公司内部网站有哪些,内网如何建网站？  如何用免费手机建站系统零基础打造专业网站？  哈尔滨网站建设策划,哈尔滨电工证查询网站？  成都网站制作公司哪家好,四川省职工服务网是做什么用？  如何将凡科建站内容保存为本地文件？  网站制作话术技巧,网站推广做的好怎么话术？  建站主机选择指南：服务器配置与SEO优化实战技巧  html制作网站的步骤有哪些,iapp如何添加网页？  C++ static_cast和dynamic_cast区别_C++静态转换与动态类型安全转换  做企业网站制作流程,企业网站制作基本流程有哪些？  北京网站制作费用多少,建立一个公司网站的费用.有哪些部分,分别要多少钱？  企业在线网站设计制作流程,想建设一个属于自己的企业网站，该如何去做？  seo网站制作优化,网站SEO优化步骤有哪些？  高端建站如何打造兼具美学与转化的品牌官网？