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);
 }
 }

}

源码地址：

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