This repository has been archived on 2021-11-25. You can view files and clone it, but cannot push or open issues or pull requests.
BookFloatingServer/BookFloatingServer.java
2017-03-08 22:09:00 +08:00

345 lines
6.5 KiB
Java

import java.sql.*;
import java.io.*;
import java.net.*;
import com.google.gson.Gson;
class Handle implements Runnable
{
private Socket s;
public Handle(Socket socket)
{
s=socket;
}
public void run()
{
System.out.println("New Connection.");
InputStream is=null;
BufferedReader br=null;
OutputStream os=null;
PrintWriter pw=null;
try
{
is=s.getInputStream();
br=new BufferedReader(new InputStreamReader(is));
os=s.getOutputStream();
pw=new PrintWriter(os);
while(true)
{
byte[] buf = new byte[1024];
int len =is.read(buf);
if(len < 0){
break;
}
String str = new String(buf,0,len);
System.out.println("String is: "+str);
Gson gson=new Gson();
AppJsonData data=null;
try
{
data=gson.fromJson(str, AppJsonData.class);
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Receive a incorrect json string.");
continue;
}
System.out.println("AppJsonData:"+data.getType());
switch(data.getType())
{
case "register":
{
RegisterData reg=null;
try
{
reg=gson.fromJson(str, RegisterData.class);
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Incorrect Register Data");
break;
}
int ret=BookFloatingServer.Register(reg.getEmail(), reg.getPass(), reg.getNickname(), reg.getSchool());
System.out.println("Register Finished. Ret("+ret+")");
pw.write("{'ret':'"+ret+"'}");
pw.flush();
}
break;
case "login":
{
LoginData login=null;
try
{
login=gson.fromJson(str, LoginData.class);
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Incorrect Login Data");
break;
}
int ret=BookFloatingServer.Login(login.getEmail(),login.getPass());
pw.write("{'ret':'"+ret+"'}");
pw.flush();
}
break;
case "getpart":
break;
case "getfull":
break;
case "upload":
break;
}
}
String reply="Connection is OK";
pw.write(reply);
pw.flush();
}
catch(Exception e)
{
e.printStackTrace();
}
finally
{
try{pw.close();}catch(Exception e){e.printStackTrace();}
try{os.close();}catch(Exception e){e.printStackTrace();}
try{br.close();}catch(Exception e){e.printStackTrace();}
try{is.close();}catch(Exception e){e.printStackTrace();}
try{s.close();}catch(Exception e){e.printStackTrace();}
}
System.out.println("Connection Lost.");
}
}
public class BookFloatingServer
{
public static int Login(String Email,String Password) {
Connection conn = null;
String url="jdbc:mysql://gameharbor.cn:3306/test";
Statement stmt = null;
ResultSet rs = null;
int ret=0;
String RemotePassword = new String();
try{
conn=DriverManager.getConnection(url,"testuser","pwdtest");
stmt=conn.createStatement();
rs=stmt.executeQuery("SELECT pwass FROM user where email=\""+Email+"\"");
if(rs.next())
{
RemotePassword=rs.getString(1);
}
if(RemotePassword.equals(Password))
{
ret=1;///Password Matchs
}
else
{
ret=0;///Password Does not Matchs
}
} catch(SQLException e) {
e.printStackTrace();
ret=-1;// Connection Error
}
finally
{
try{
if(rs!=null) rs.close();
} catch(SQLException e) {
e.printStackTrace();
}
try{
if(stmt!=null) stmt.close();
} catch(SQLException e){
e.printStackTrace();
}
try{
if(conn!=null) conn.close();
} catch(SQLException e) {
e.printStackTrace();
}
}
return ret;
}
public static int Register(String Email,String Password,String Nickname,String School){
int upret=-1;
Connection conn=null;
String url="jdbc:mysql://gameharbor.cn:3306/test";
PreparedStatement stmt = null;
try{
conn=DriverManager.getConnection(url,"testuser","pwdtest");
String sqlString=new String("INSERT into test.user VALUES (?,?,?,?,?,?)");
stmt=conn.prepareStatement(sqlString,Statement.RETURN_GENERATED_KEYS);
stmt.setString(1,Email);
stmt.setString(2, Password);
stmt.setString(3, Nickname);
stmt.setString(4, School);
stmt.setString(5, "");
stmt.setString(6, "");
upret=stmt.executeUpdate();
} catch(SQLException e) {
e.printStackTrace();
} finally {
try {
if(stmt!=null) stmt.close();
} catch(SQLException e) {
e.printStackTrace();
}
try{
if(conn!=null) conn.close();
} catch(SQLException e) {
e.printStackTrace();
}
}
return upret;
}
public static void main(String[] args) {
/*
try {
Class.forName("com.mysql.jdbc.Driver");
} catch (ClassNotFoundException e) {
e.printStackTrace();
System.exit(-1);
}
/// ret=Login("test2@me.com","030201");
int ret=Register("test3@me.com","030201","LiuTongYuan","QUST");
System.out.println("Ret is "+ret);
*/
System.out.println("Program Started.");
ServerSocket ss=null;
try
{
ss=new ServerSocket(55555);
}
catch(IOException e)
{
e.printStackTrace();
System.out.println("Error while create ServerSocket.");
System.exit(0);
}
while(true)
{
Socket s=null;
try
{
s=ss.accept();
Thread workThread=new Thread(new Handle(s));
workThread.start();
}
catch(Exception e)
{
e.printStackTrace();
System.out.println("Error while starting a new connection.");
break;
}
}
try
{
ss.close();
}
catch(Exception e)
{
e.printStackTrace();
}
}
}
/*
import java.io.*;
import java.net.*;
public class BookFloatingServer {
public class ServerThread implements Runnable
{
Socket s=null;
BufferedReader br=null;
public ServerThread(Socket s)
{
System.out.println("Thread Ready, ID="+Thread.currentThread().getId());
this.s=s;
try
{
br=new BufferedReader(
new InputStreamReader(
s.getInputStream())
);
}
catch(Exception e)
{
e.printStackTrace();
return;
}
}
public void run()
{
System.out.println("Thread Start, ID="+Thread.currentThread().getId());
try
{
s.close();
}
catch(Exception e)
{
e.printStackTrace();
}
System.out.println("Thread Over, ID="+Thread.currentThread().getId());
}
}
public static void main(String[] args)
{
ServerSocket ss;
try
{
ss=new ServerSocket(50001);
}
catch(Exception e)
{
e.printStackTrace();
return;
}
while(true)
{
Socket s;
try
{
s=ss.accept();
}
catch(Exception e)
{
e.printStackTrace();
continue;
}
new Thread(new ServerThread(s)).start();
}
}
}
*/