热门标签 | HotTags
当前位置:  开发笔记 > 运维 > 正文

androidsocket聊天室功能实现

这篇文章主要为大家详细介绍了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();


 }
}

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

<&#63;xml version="1.0" encoding="utf-8"&#63;>


 

 

 

服务器:

MySever

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

public class MySever {

 public static ArrayList socketList = new ArrayList();
 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 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 九宫格布局详解及实现:人人网应用示例
    本文深入探讨了人人网Android应用中独特的九宫格布局设计,解析其背后的GridView实现原理,并提供详细的代码示例。这种布局方式不仅美观大方,而且在现代Android应用中较为少见,值得开发者借鉴。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • 本文详细介绍了如何使用PHP检测AJAX请求,通过分析预定义服务器变量来判断请求是否来自XMLHttpRequest。此方法简单实用,适用于各种Web开发场景。 ... [详细]
  • 深入理解Cookie与Session会话管理
    本文详细介绍了如何通过HTTP响应和请求处理浏览器的Cookie信息,以及如何创建、设置和管理Cookie。同时探讨了会话跟踪技术中的Session机制,解释其原理及应用场景。 ... [详细]
  • 本文探讨了 RESTful API 和传统接口之间的关键差异,解释了为什么 RESTful API 在设计和实现上具有独特的优势。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • 360SRC安全应急响应:从漏洞提交到修复的全过程
    本文详细介绍了360SRC平台处理一起关键安全事件的过程,涵盖从漏洞提交、验证、排查到最终修复的各个环节。通过这一案例,展示了360在安全应急响应方面的专业能力和严谨态度。 ... [详细]
  • Android LED 数字字体的应用与实现
    本文介绍了一种适用于 Android 应用的 LED 数字字体(digital font),并详细描述了其在 UI 设计中的应用场景及其实现方法。这种字体常用于视频、广告倒计时等场景,能够增强视觉效果。 ... [详细]
  • RecyclerView初步学习(一)
    RecyclerView初步学习(一)ReCyclerView提供了一种插件式的编程模式,除了提供ViewHolder缓存模式,还可以自定义动画,分割符,布局样式,相比于传统的ListVi ... [详细]
  • 解决JAX-WS动态客户端工厂弃用问题并迁移到XFire
    在处理Java项目中的JAR包冲突时,我们遇到了JaxWsDynamicClientFactory被弃用的问题,并成功将其迁移到org.codehaus.xfire.client。本文详细介绍了这一过程及解决方案。 ... [详细]
  • 探讨如何真正掌握Java EE,包括所需技能、工具和实践经验。资深软件教学总监李刚分享了对毕业生简历中常见问题的看法,并提供了详尽的标准。 ... [详细]
  • 本文介绍如何使用布局文件在Android应用中排列多行TextView和Button,使其占据屏幕的特定比例,并提供示例代码以帮助理解和实现。 ... [详细]
  • 本文探讨了在Windows Server 2008环境下配置Tomcat使用80端口时遇到的问题,包括端口被占用、多项目访问失败等,并提供详细的解决方法和配置建议。 ... [详细]
  • 在当前众多持久层框架中,MyBatis(前身为iBatis)凭借其轻量级、易用性和对SQL的直接支持,成为许多开发者的首选。本文将详细探讨MyBatis的核心概念、设计理念及其优势。 ... [详细]
  • 将Web服务部署到Tomcat
    本文介绍了如何在JDeveloper 12c中创建一个Java项目,并将其打包为Web服务,然后部署到Tomcat服务器。内容涵盖从项目创建、编写Web服务代码、配置相关XML文件到最终的本地部署和验证。 ... [详细]
author-avatar
ccmm6688
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有