Tomact和MySql搭建android简单服务器
之前已经写了怎么搭建eclipse加tomcat整合成服务器环境，如果有人不知道怎么配置，可以看我的那篇博客。
现在环境搭配好的情况下，在eclipse里新建一个Web工程，在src包下新建一个servlet。
@WebServlet("/UserServlet")
public class UserServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
//============add
List<String> mList=new ArrayList<>();
private StringBuffer UIDS;
public UserServlet() {
super();
}
public void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
//在服务器端解决中文乱码问题
response.setContentType("text/html;charset=utf-8");
request.setCharacterEncoding("utf-8");
response.setCharacterEncoding("utf-8");
if(request.getParameter("userName")==null || request.getParameter("passWord")==null){
return;
}
String userName="",passWord="";
// //根据请求类型解决中文乱码问题
if(request.getMethod().equalsIgnoreCase("GET")) {
userName = new String(request.getParameter("userName").getBytes("iso-8859-1"),"utf-8");
passWord = new String(request.getParameter("passWord").getBytes("iso-8859-1"),"utf-8");
}else{
userName = new String(request.getParameter("userName").getBytes());
passWord = new String(request.getParameter("passWord").getBytes());
}
System.out.println("账号："+userName);
System.out.println("密码："+passWord);
//连接数据库,使用局部变量防止并发问题
selectUser(userName,passWord,response);
}
protected void doPost(HttpServletRequest request,
HttpServletResponse response) throws ServletException, IOException {
this.doGet(request, response);
}
private void selectUser(String userName,final String passWord,HttpServletResponse response) {
List<Person> persons=new ArrayList<>();
JDBCUtil j=new JDBCUtil();
String sql="select * from user where account = '"+userName+"' and password = '"+passWord+"'";
//新建一个json数据返回客户端
String jsonString="";
try {
ResultSet rs=j.query(sql);
if(rs.next()){
System.out.println("id"+"\t"+"账号"+"\t"+"密码"+"\t"+"摄像机名称"+"\t"+"UID"+"\t"+"用户名"+"\t"+"用户密码"+"\t");
rs.previous();
}
while(rs.next()){
int id=rs.getInt(1);
String n=rs.getString(2);
String s=rs.getString(3);
String cname=rs.getString(4);
String UID=rs.getString(5);
String name=rs.getString(6);
String cpassword=rs.getString(7);
System.out.println(id+"\t"+n+"\t"+s+"\t"+cname+"\t"+UID+"\t"+name+"\t"+cpassword+"\t");
Person person=new Person(id,n,s,cname,UID,name,cpassword);
persons.add(person);
}
//判断查询结果
if(persons.size()>0){
jsonString = JsonTools.createJsonString("strings",DataUtil.getPersons(persons));
response.getWriter().print(jsonString);
persons.clear();
}else{
response.getOutputStream().print("fail");
}
} catch (Exception e) {
// TODO: handle exception
}finally {
j.close();
}
}
}
在servlet里用到了一个实体类Person.
public class Person {
int id;
String account;
String password;
String name;
String uid;
String cname;
String cpassword;
public Person() {
// TODO Auto-generated constructor stub
}
public Person(int id, String account, String password, String name, String uid, String cname, String cpassword) {
super();
this.id = id;
this.account = account;
this.password = password;
this.name = name;
this.uid = uid;
this.cname = cname;
this.cpassword = cpassword;
}
public int getId() {
return id;
}
public void setId(int id) {
this.id = id;
}
public String getAccount() {
return account;
}
public void setAccount(String account) {
this.account = account;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
public String getUid() {
return uid;
}
public void setUid(String uid) {
this.uid = uid;
}
public String getCname() {
return cname;
}
public void setCname(String cname) {
this.cname = cname;
}
public String getCpassword() {
return cpassword;
}
public void setCpassword(String cpassword) {
this.cpassword = cpassword;
}
// String id;
// String account;
// String password;
// String name;
// String uid;
// String cname;
// String cpassword;
@Override
public String toString() {
return "Person [id=" + id + ", account=" + account + ", password=" + password
+ ", name=" + name + ", uid=" + uid +", cname=" + cname +", cpassword=" + cpassword +"]";
}
}
然后根据接收的用户名和密码查找数据库，所有首先必须安装MySQL数据库，在网上下载MySQL数据库，具体安装可以参考http://www.jb51.net/article/23876.htm，安装完成后，最后下载一个视图工具管理Mysql，我用的是Navicat for MySQL，网上可以下载并且破解。然后新建user表，字段和Person实体类对应。随便写入一些数据。
由于连接数据库需要用的JDBC架包，所以去网上下载Mysql数据库的JDBC架包，在工程下新建lib目录，把架包拷入lib目录，让后邮寄点击架包，build path->add buildpath，把架包加入工程。这样还不够，web项目必须把架包拷入Tomcat的lib目录下，否则会报找不到架包的错误。
在src包下还有一个JDBC类，封装了数据库的操作：
public class JDBCUtil {
private static String Driver="com.mysql.jdbc.Driver";
private String url="jdbc:mysql://localhost:3306/aa?characterEncoding=utf-8";
private String user="root";
private String pwd="123456";
private Connection conn=null;
private PreparedStatement ps=null;
//1,加载驱动(一次加载)
static{
try {
Class.forName(Driver);
} catch (ClassNotFoundException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//2,建立连接
public void getConn(){
try {
conn=DriverManager.getConnection(url,user,pwd);
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
//3,创建sql对象，执行sql语句，处理结果集(增，删，改)
public int update(String sql,Object obj[]){
getConn();
int k=0;
try {
ps=conn.prepareStatement(sql);
if(obj!=null){
for(int i=0;i<obj.length;i++){
ps.setObject((i+1), (String)obj[i]);
}
}
k=ps.executeUpdate();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
close();
return k;
}
//4,查询
public ResultSet query(String sql){
getConn();
ResultSet rs=null;
try {
ps=conn.prepareStatement(sql);
rs=ps.executeQuery();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return rs;
}
//5,释放资源
public void close(){
try {
if(ps!=null){
ps.close();
}
if(conn!=null){
conn.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
至此服务器的代码编写基本完成，然后编写客户端的代码。
在android端新建一个类JsonTools，负责解析服务器传回的json数据。
public static List<Person> getPersons(String key, String jsonString) {
List<Person> list = new ArrayList<Person>();
JSONObject jsonObject;
try {
jsonObject = new JSONObject(jsonString);
JSONArray Persons = jsonObject.getJSONArray(key);
for (int i = 0; i < Persons.length(); i++) {
Person person = new Person();
JSONObject jsonObject2 = Persons.getJSONObject(i);
person.setId(jsonObject2.getInt("id"));
person.setAccount(jsonObject2.getString("account"));
person.setPassword(jsonObject2.getString("password"));
person.setName(jsonObject2.getString("name"));
person.setUid(jsonObject2.getString("uid"));
person.setCname(jsonObject2.getString("cname"));
person.setCpassword(jsonObject2.getString("cpassword"));
list.add(person);
}
} catch (JSONException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return list;
}
然后新建一个类UserService，负责发送POST请求和接收服务器返回的数据。
/**
* DOPost请求
*/
private static String sendPOSTRequest(String path,
Map<String, String> params,String encode) throws MalformedURLException, IOException {
byte[] data = getRequestData(params, encode).toString().getBytes();//获得请求体
//此处不能把path变成StringBuilder,否则会崩溃
HttpURLConnection conn=(HttpURLConnection)new URL(path).openConnection();
conn.setConnectTimeout(5000);
//=================
conn.setDoInput(true); //打开输入流，以便从服务器获取数据
conn.setDoOutput(true); //打开输出流，以便向服务器提交数据
conn.setRequestMethod("POST"); //设置以Post方式提交数据
conn.setUseCaches(false);
// conn.setRequestProperty();
//设置请求体的类型是文本类型
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
//设置请求体的长度
conn.setRequestProperty("Content-Length", String.valueOf(data.length));
OutputStream outputStream = conn.getOutputStream();
outputStream.write(data);
if(conn.getResponseCode()==200)
{
InputStreamReader in=new InputStreamReader(conn.getInputStream());
BufferedReader bufferedReader=new BufferedReader(in);
String result="";
String readLine=null;
while ((readLine=bufferedReader.readLine())!=null){
result +=readLine;
}
in.close();
return result;
}
conn.disconnect();
return null;
}
public static String checkPost(String name, String pass) {
String path="http://192.168.1.190:8080/MyWeb/UserServlet";
//将用户名和密码放入HashMap中
Map<String,String> params=new HashMap<String,String>();
params.put("userName", name);
params.put("passWord", pass);
try {
return sendPOSTRequest(path,params,"UTF-8");
} catch (MalformedURLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return null;
}
/*
* Function : 封装请求体信息
* Param : params请求体内容，encode编码格式
*/
public static StringBuffer getRequestData(Map<String, String> params, String encode) {
StringBuffer stringBuffer = new StringBuffer(); //存储封装好的请求体信息
try {
for(Map.Entry<String, String> entry : params.entrySet()) {
stringBuffer.append(entry.getKey())
.append("=")
.append(URLEncoder.encode(entry.getValue(), encode))
.append("&");
}
stringBuffer.deleteCharAt(stringBuffer.length() - 1); //删除最后的一个"&"
} catch (Exception e) {
e.printStackTrace();
}
return stringBuffer;
}
这其中checkPost是用来接收界面传递的用户名密码，然后封装成Map,然后调用sendPOSTRequest()发送post请求，并且返回服务器传来的json数据。getRequestData（）用来把Map参数封装成Post请求的请求体。
然后就可以编写主界面的activity。
public class LoginActivity extends Activity {
private EditText userName;
private EditText passWord;
//===============
private String result=null;
private TextView mTextView;
private List<Person> mPersons =new ArrayList<>();
@Override
public void onCreate(Bundle savedInstanceState) {
super.onCreate(savedInstanceState);
setContentView(R.layout.activity_main);
userName=(EditText)this.findViewById(R.id.userName);
passWord=(EditText)this.findViewById(R.id.password);
mTextView= (TextView) findViewById(R.id.tv_info);
findViewById(R.id.btn_connect).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
login();
}
});
findViewById(R.id.btn_connectPost).setOnClickListener(new View.OnClickListener() {
@Override
public void onClick(View view) {
loginPost();
}
});
}
private void clearEditTexts() {
// userName.setText("");
// passWord.setText("");
result=null;
}
/**
* 用户登录的方法
*/
public void login()
{
//取得用户输入的账号和密码
final String name=userName.getText().toString();
final String pass=passWord.getText().toString();
new Thread(new Runnable() {
@Override
public void run() {
result=UserService.check(name,pass);
runOnUiThread(new Runnable() {
@Override
public void run() {
if (result!=null){
if (result.equals("fail")){
Toast.makeText(LoginActivity.this,"fail",Toast.LENGTH_LONG).show();
clearEditTexts();
}else {
mTextView.setText(result);
}
}else {
Toast.makeText(LoginActivity.this,"null",Toast.LENGTH_LONG).show();
}
}
});
}
}).start();
}
/**
* 采用post请求
*/
public void loginPost()
{
//取得用户输入的账号和密码
final String name=userName.getText().toString();
final String pass=passWord.getText().toString();
new Thread(new Runnable() {
@Override
public void run() {
result=UserService.checkPost(name,pass);
runOnUiThread(new Runnable() {
@Override
public void run() {
if (result!=null){
if (result.equals("fail")||result.equals("")){
Toast.makeText(LoginActivity.this,"用户名或密码错误",Toast.LENGTH_LONG).show();
clearEditTexts();
}else {
mPersons= JsonTools.getPersons("strings",result);
StringBuffer buffer=new StringBuffer();
for (int i=0;i<mPersons.size();i++){
Person Person=mPersons.get(i);
buffer.append(Person.getId()+"\t"+Person.getAccount()+"\t"+Person.getPassword()+"\t"+Person.getName()+"\t"+Person.getUid()+"\t"+Person.getCname()+"\t"+Person.getCpassword()+"\t");
buffer.append("\r\n");
}
mTextView.setText(buffer.toString());
clearEditTexts();
}
}else {
Toast.makeText(LoginActivity.this,"访问服务器失败",Toast.LENGTH_LONG).show();
}
}
});
}
}).start();
}
}
界面的布局很简单
<?xml version="1.0" encoding="utf-8"?>
<RelativeLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:tools="http://schemas.android.com/tools" android:layout_width="match_parent"
android:layout_height="match_parent" android:paddingLeft="@dimen/activity_horizontal_margin"
android:paddingRight="@dimen/activity_horizontal_margin"
android:paddingTop="@dimen/activity_vertical_margin"
android:paddingBottom="@dimen/activity_vertical_margin" tools:context=".MainActivity">
<TextView
android:id="@+id/tv_info"
android:text="hello_world"
android:layout_width="wrap_content"
android:layout_height="wrap_content" />
<LinearLayout
android:layout_width="match_parent"
android:layout_height="wrap_content"
android:orientation="horizontal"
android:layout_below="@+id/tv_info"
android:id="@+id/mLiner">
<Button
android:text="ConnectGet"
android:layout_width="0dp"
android:layout_weight="1"
android:layout_height="wrap_content"
android:id="@+id/btn_connect"/>
<Button
android:text="ConnectPost"
android:layout_width="0dp"
android:layout_weight="1"
android:layout_height="wrap_content"
android:id="@+id/btn_connectPost"/>
</LinearLayout>
<LinearLayout
android:layout_width="match_parent"
android:layout_height="48dp"
android:layout_below="@+id/liner"
android:orientation="horizontal"
android:gravity="center_vertical">
<TextView
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="密码:"
android:gravity="center|left"
android:textSize="15sp"
/>
<EditText
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="3"
android:id="@+id/password"
android:password="true"
android:textSize="15sp"
android:background="@drawable/bg_edittext"
android:padding="5dp"
android:textCursorDrawable="@null"
/>
</LinearLayout>
<LinearLayout
android:id="@+id/liner"
android:layout_width="match_parent"
android:layout_height="48dp"
android:orientation="horizontal"
android:gravity="center_vertical"
android:layout_below="@+id/mLiner"
android:layout_alignParentLeft="true"
android:layout_alignParentStart="true">
<TextView
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="1"
android:text="用户名:"
android:gravity="center|left"
android:textSize="15sp"
/>
<EditText
android:layout_width="0dp"
android:layout_height="wrap_content"
android:layout_weight="3"
android:id="@+id/userName"
android:textSize="15sp"
android:padding="5dp"
android:background="@drawable/bg_edittext"
android:textCursorDrawable="@null"/>
</LinearLayout>
</RelativeLayout>
其中editText是自定义的样式，如果报错可以把样式删除，或者参考我的另一篇博客EditText的设置边框样式。
由于访问网络，所有manifest文件记得加入网络权限
<uses-permission android:name="android.permission.INTERNET"/>
这样，一个android客户端就完成了。
由于此次博客的内容量太大，我感觉很难讲明白，不过效果完全可以做出来。做android开发的可以看看，我觉得会些服务器的知识才能更好的做android开发。如果大家有什么问题，欢迎给我留言，我看到后会回复。
Tomact和MySql搭建android简单服务器相关推荐
- python django mysql安装_Django+Nginx+uWSGI+Mysql搭建Python Web服务器
原标题:Django+Nginx+uWSGI+Mysql搭建Python Web服务器 安装的时候全部选择英文,记得以前选择中文的时候安装时出了问题,服务器组件一个不选,Ubuntu安装做的很贴心,基 ...
- Ubuntu+Django+Nginx+uWSGI+Mysql搭建Python Web服务器
Ubuntu+Django+Nginx+uWSGI+Mysql搭建Python Web服务器 闲着无聊的时候部署了一个Django项目玩,用vm虚拟机部署的. 准备工作 我使用的系统是Ubuntu16 ...
- android 自动更新 服务端,搭建android版本更新服务器使用android系统自带的DownloadManager下载文件...
这几天想自己做一个文件更新的功能,但是由于不知道怎样写服务端,所以一直没有去做,后来发现原来服务端编写简直是太简单了,所以今天就实现了 版本更新的这样一个功能. 一搭建版本更新服务器: 搭建这个一个服 ...
- Python后端---使用Django+Mysql搭建一个简单的网站
提示:文章写完后,目录可以自动生成,如何生成可参考右边的帮助文档 文章目录 前言 一.项目搭建 前期准备 命令行创建项目和app Django项目配置文件说明 使用数据库 编写业务逻辑 配置url主路 ...
- android简单服务器的搭建
昨天,组长让我试着搭一个服务器,用于做客户端app的登录与注册功能.以前一直以为做android只需要写好app就可以,这次发行可以尝试服务器的编写,也让我学会了做android开发不仅要写好客户端, ...
- centos rsyslog mysql_centos7+rsyslog+loganalyzer+mysql 搭建rsyslog日志服务器
一.简介 在centos7系统中,默认的日志系统是rsyslog,它是一类unix系统上使用的开源工具,用于在ip网络中转发日志信息,rsyslog采用模块化设计,是syslog的替代品. 1.rsy ...
- centos7 修改连接数_centos7+rsyslog+loganalyzer+mysql 搭建rsyslog日志服务器 - 夜空守望者2020...
在centos7系统中,默认的日志系统是rsyslog,它是一类unix系统上使用的开源工具,用于在ip网络中转发日志信息,rsyslog采用模块化设计,是syslog的替代品. 1.rsyslog特 ...
- boost asio 文件服务器,基于boost::asio封装搭建的简单服务器
经过一天的简单学习,尝试自己写一个简单的服务器,能够实现以下三大回调功能:onConnect onMessage onClose 下面直接贴出代码 1.BaseServer抽象类 BaseServer ...
- 如何使用PHP和MySQL搭建一个简单的算命网站
算命是一种古老的传统文化,对于很多人来说,算命可以帮助他们解决一些问题,预知未来的发展趋势.现在,我们将通过开源算命的 php 源码来帮助那些想要自己搭建算命网站的人. 一.搭建环境 首先,我们需要搭 ...
最新文章
- Java 中的内存溢出和内存泄露是什么？我给你举个有味道的例子
- OGG维护优化脚本（一）-需求分析篇
- 传送门（portal）
- C#操作Excel，权限问题
- 暗通道优先的图像去雾算法（下）
- C语言 | 快排双向扫描：快速排序双向扫描分区法（源代码）
- 深入理解javascript原型和闭包（17）——补this
- jquery 判断控件css样式,jQuery获取并设置CSS类
- 病毒周报(100118至100124)
- 2010年过年左右时的艾米果
- 管理感悟：主管加班，员工才会加班
- 400款营销策划PPT模板免费下载
- 启发式算法（Heuristic Algorithm）
- “领域知识图谱的构建与应用”讲座学习笔记
- sap crm button_如何安装SAP软件？
- matlab2c使用c++实现matlab函数系列教程-imag函数
- 自然语言处理和编译器的对比
- 关于智能家居、360wifi、wifi开关，以及wifi芯片的选择
- 物流管理扫码器识别不了条码怎么办
- 《无尽战神》隐私政策