androidsocket聊天室功能实现-创新互联

前提概要

笔者很久之前其实就已经学习过了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();


 }
}