1.创建自己的MyServletContextListener.java:
package yybwb; import java.net.ServerSocket; import javax.servlet.ServletContextEvent; import javax.servlet.ServletContextListener; public class MyServletContextListener implements ServletContextListener { //这里使该类实现 ServletContextListener监听接口,在Tomcat启动时会调用实现该接口 //的 contextInitialized方法 ServerSocket ss = null;//声明ServerSocket对象 ServerThread st = null;//声明ServerThread对象 //创建服务线程,并将其启动,本方法在tomca启动时调用 public void contextInitialized(ServletContextEvent sce){ try{ ss = new ServerSocket(8888); st = new ServerThread(ss); st.start(); }catch(Exception e){ e.printStackTrace(); } } //停止服务线程,本方法在tomca停止时调用 public void contextDestroyed(ServletContextEvent sce){ try{ st.flag = false; ss.close(); ss = null; st = null; }catch(Exception e){ e.printStackTrace(); } } }
2.在Web.xml中配置上面的监听类
<Listener> <Listener-class>XX.MyServletContextListener</Listener-class> </Listener>
3.创建服务线程ServerThread类如:
package yybwb; import java.net.ServerSocket; import java.net.Socket; import java.net.SocketException; public class ServerThread extends Thread{ public ServerSocket ss; //声明ServerSocket对象 public boolean flag = false; //循环标志位 public ServerThread(ServerSocket ss){ //构造器 this.ss = ss; flag = true; } //run方法创建ServerSocket 监听 public void run(){ while(flag){ try{ Socket socket = ss.accept(); //客户连接后,创建代理线程 ServerAgent,负责与该客户的通讯 ServerAgent sa = new ServerAgent(socket); sa.start(); } catch(SocketException se){ try{ ss.close(); ss = null; System.out.println("ServerSocket closed"); }catch(Exception ee){ ee.printStackTrace(); } } catch(Exception e){ e.printStackTrace(); } } } }
4.代理线程ServerAgent,如:
package yybwb; /**LastDate:2014-10-22 * 更新菜单-#GET_MENULIST# * Author:Wuchyuan */ import static yybwb.ConstantUtil.DELETE_SUCCESS; import static yybwb.ConstantUtil.DIARY_SUCCESS; import static yybwb.ConstantUtil.REGISTER_FAIL; import static yybwb.ConstantUtil.UPDATE_STATE_SUCCESS; import java.io.DataInputStream; import java.io.DataOutputStream; import java.io.EOFException; import java.io.IOException; import java.net.Socket; import java.net.SocketException; import java.sql.Blob; import java.util.ArrayList; import java.util.List; public class ServerAgent extends Thread{ public Socket socket; public DataInputStream din; public DataOutputStream dout; boolean flag = false; public ServerAgent(Socket socket) { this.socket = socket; try { this.din = new DataInputStream(socket.getInputStream()); this.dout = new DataOutputStream(socket.getOutputStream()); flag =true; } catch (IOException e) { e.printStackTrace(); } } //方法:线程执行方法 public void run(){ while(flag){ try { String msg = din.readUTF(); //接收客户端发来的消息 // System.out.println("收到的消息是:"+msg); if(msg.startsWith("<#LOGIN#>")){ //消息为登录 String content = msg.substring(9); //获得消息内容 String [] sa = content.split("\\|"); ArrayList<String> result = DBUtil.checkLogin(sa[0], sa[1]); if(result.size()>1){ //登录成功 StringBuilder sb = new StringBuilder(); sb.append("<#LOGIN_SUCCESS#>"); for(String s:result){ sb.append(s); sb.append("|"); } String loginInfo = sb.substring(0,sb.length()-1); dout.writeUTF(loginInfo); //返回用户的基本信息 } else{ //登录失败 String loginInfo = "<#LOGIN_FAIL#>"+result.get(0); dout.writeUTF(loginInfo); } } //mealSvr发来的消息 2014-7-9 else if(msg.startsWith("<#PRINT_DINGD#>")){ //消息为查询打印订单2014-7-9 msg = msg.substring(15); //提取内容 String [] sa = msg.split("\\|"); //分割字符串 boolean result = DBUtil.QueryPrint(sa[0]); //查询是否有需打印订单 // if(result){ //有订单 dout.writeUTF("<#HAVE_DINGD#>"); //发回成功消息 dout.flush(); } else{ dout.writeUTF("<#NOT_DINGD#>"); //发回创建失败消息 dout.flush(); } } //2014-10-22 检查用户密码 else if(msg.startsWith("<#CHECK_USERPASSWD#>")){ // msg = msg.substring(20); //提取内容 String [] sa = msg.split("\\|"); //分割字符串 boolean result = DBUtil.CheckUserPw(sa[0],sa[1]); //查询是否有需打印订单 System.out.println("查询"+sa[0]+"密码是否正确"); if(result){ //有 dout.writeUTF("<#CHECKPWD_HAVE#>"); //发回成功消息 dout.flush(); } else{ dout.writeUTF("<#CHECKPWD_NOT#>"); //发回创建失败消息 dout.flush(); } } } } catch(SocketException se){ try { dout.close(); din.close(); socket.close(); socket = null; flag = false; } catch (IOException e) { e.printStackTrace(); } } catch(EOFException eof){ try { dout.close(); din.close(); socket.close(); socket = null; flag = false; } catch (IOException e) { e.printStackTrace(); } } catch (Exception e) { e.printStackTrace(); } } } }
Android服务端的设计的更多相关文章
-
Android 服务端开发之开发环境配置
Android 服务端开发之开发环境配置 这里是在Eclipse的基础上安装PhpEclipse插件方法,PHPEclipse是Eclipse的 一个用于开发PHP的插件.当然也可以采用Java开发a ...
-
erlang-百度云推送Android服务端功能实现-erlang
百度云推送官方地址http://developer.baidu.com/wiki/index.php?title=docs/cplat/push 简单的介绍下原理: 百度云推送支持IOS和Androi ...
-
从服务端架构设计角度,深入理解大型APP架构升级
随着智能设备普及和移动互联网发展,移动端应用逐渐成为用户新入口,重要性越来越突出.但企业一般是先有PC端应用,再推APP,APP 1.0版的功能大多从现有PC应用平移过来,没有针对移动自身特点考虑AP ...
-
移动APP服务端API设计应该考虑到的问题
2014年,移动APP的热度丝毫没有减退,并没有像桌面软件被WEB网站那样所取代, 不但如此,越来越多的传统应用.网站也都开始制作自己的移动APP,也就是我们常说的IOS客户端.android客户端. ...
-
APP和服务端-架构设计(二)
1. App架构设计经验谈:接口的设计 App与服务器的通信接口如何设计得好,需要考虑的地方挺多的,在此根据我的一些经验做一些总结分享,旨在抛砖引玉. 1.1 安全机制的设计 现在,大部分App的接口 ...
-
APP和服务端-架构设计(一)
架构因人而异,不同的架构师大多会有不同的看法:架构也因项目而异,不同的项目需求不同,相应的架构也会不同.然而,有些东西还是通用的,是所有架构师都需要考虑的,也是所有项目都会有的需求,比如API如何设计 ...
-
delphi xe5 android 服务端和手机端的源码下载
xe5 android的服务端和手机客户端的源代码下载地址 http://files.cnblogs.com/nywh2008/AndroidTest.rar
-
谈一款MOBA游戏《码神联盟》的服务端架构设计与实现
一.前言 <码神联盟>是一款为技术人做的开源情怀游戏,每一种编程语言都是一位英雄.客户端和服务端均使用C#开发,客户端使用Unity3D引擎,数据库使用MySQL.这个MOBA类游戏是笔者 ...
-
谈一款MOBA类游戏《码神联盟》的服务端架构设计与实现(更新优化思路)
注:本文仅用于在博客园学习分享,还在随着项目不断更新和完善中,多有不足,暂谢绝各平台或个人的转载和推广,感谢支持. 一.前言 <码神联盟>是一款为技术人做的开源情怀游戏,每一种编程语言都是 ...
随机推荐
-
安卓---Toast工具类,有点懒
package com.liunan.myfirstapp.util; import android.content.Context; import android.widget.Toast; /** ...
-
经典SQL语句大全 学者必看
一.基础 .说明:创建数据库 CREATE DATABASE database-name .说明:删除数据库 drop database dbname .说明:备份sql server --- 创建 ...
-
关于.net中的脚本语言使用
基于.net中drl框架的脚本现在有很多,最近也由于工作的需要,目前有lua.python.ruby.javascript的.net实现,对ruby不怎么了解,python.lua.js就成了试验的对 ...
-
十款PHP开发框架对比
PHP开发框架近来在PHP社区中成为讨论的热点,几乎每天都在推出新的框架.面对市面上超过四十种的开发框架,你很难判断究竟哪一款最适合你,尤其是在这些框架所提供的功能不尽相同的时候. 本文将引导你 ...
-
mongodb数据库操作--备份 还原 导出 导入
首先数据库备份: mongodump -h IP --port 端口 -u 用户名 -p 密码 -d 数据库 -o 文件存在路径 mongodump -h 127.0.0.1 -u admin -p ...
-
as3中去掉字符串两边的空格,换行符
as3 去掉字符串两边的空格,换行符,方法一 ActionScript Code 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 pub ...
-
应邀ITGeGe在线教育社区嵌入式基础开发讲师
最近,被一家IT在线公司邀请去做嵌入式基础课程的讲师,我感觉非常荣幸,虽然我还是菜鸟一个,难得有这样的企业会看得起我,这也是对我的一个磨练吧,可以培养我继续不断学习技术的动力,同时还能将技术通过自身的 ...
-
Groovy 设计模式 -- null对象模式
Null Object Pattern http://groovy-lang.org/design-patterns.html#_loan_my_resource_pattern 对于一些场景获得的对 ...
-
多个SDK控制管理
需求:制作一个公共组件,可以实现多个SDK想用哪个用哪个,集中管理 组织方式: 架构形式 注意点: 1.sdk必须通过maven库来compile,因为jar会打到aar中:所以library和主mo ...
-
Docker Kubernetes Service 代理服务创建
Docker Kubernetes Service 代理服务创建 创建Service需要提前创建好pod容器.再创建Service时需要指定Pod标签,它会提供一个暴露端口默会分配容器内网访问的唯一 ...