定义scoket和字符输入输出流
Socket socket =new Socket(InetAddress.getName(str),6789);
//新建scoket 参数是IP地址和端口号
PrintWriter out=new PrintWriter(socket.getOutputStream);
//根据outputstream实例生成PrintWriter实例
/**java是unicode编码,是双字节的
Reader用于字符的读(字符数据的输入) Writer用于字符的读(字符数据的输出)
而InputStream 是输入流(外部文件输入内存) read方法 从输入流读取
outputStream输出流(内存输出到文件) write 写入该输出流
*/
读取数据到内存所以是输入
写数据是内存输出到文件
BufferReader in=new BufferReader(new InputStream(socket.getInputStream, "utf-8"));
//字节流转换成字符流 BufferReader 设置编码格式
字节流是原始数据,用户读入后需要进行相应的编码转换 字符流是自动转换的
Gson
Gson gson=new Gson();
While(true){
Map map=new HashMap();
map.put("ceshi","ok");
map.put("imei",str);//key+value
String back=gson.toJson(map);//利用gson将map(或Java对象)转换为json字符串
out.println(back);//打印该字符串
out.flush();//刷新该流的缓冲
String getback=in.readLine();//获取返回的字符串
Map<String,String> retmap=gson.fromJson(getback,new TypeToken<Map<String,String>>()){}.getType());
//将返回的json字符串 反序列化成map(或者Java对象)
String id=(String)retmap.get("id");
String name=(String)retmap.get("name");
String age=(String)retmap.get("age");
}
服务端 建立线程监听
//初始化该Socket对应的输入流 解决中文乱码 使用utf-8
br = new BufferedReader(new InputStreamReader(
s.getInputStream() , "utf-8"));
out=new BufferedWriter(new OutputStreamWriter(s.getOutputStream()));
sout = new PrintWriter(s.getOutputStream());
String content = null;
//采用循环不断从Socket中读取客户端发送过来的数据
Gson gson =new Gson();
if ((content = readFromClient()) != null)
{
Map<String, String> retMap = gson.fromJson(content,
new TypeToken<Map<String, String>>() {
}.getType());
//将json字符串content转换成map
if(retMap.size()==2)
{
//向手机端发送数据 mapsize是key的数量
String ostr="yes";
OutputStream os = s.getOutputStream();
os.write((ostr + "\n").getBytes("utf-8"));
String jstr=(String)retMap.get("ceshi");
tring imei=(String)retMap.get("imei");
try {
//判断当前时间
if(jstr.equals("ok")){
//返回信息
Sqlcon scon =new Sqlcon();
Connection conn = scon.getConnection();
//Statement smt=conn.createStatement();
String sql="INSERT into dbo.Time values(?,?);";//sql语句中末尾的分号可有可无
PreparedStatement ppst=conn.prepareStatement(sql);
ppst.setString(1,imei);//对sql语句中的每个?按顺序赋值,赋值的方法取决于数据库的字段属性,我的字段属性都是字符串类型
Date date=new java.util.Date();
DateFormat df = new SimpleDateFormat("yyyy/MM/dd HH:mm:ss");//设置显示格式
String nowTime= df.format(date);//用DateFormat的format()方法在dt中获取并以yyyy/MM/dd HH:mm:ss格式显示
//System.out.println(nowTime);
ppst.setString(2, nowTime);
ppst.executeUpdate();
//System.out.println("手机端签到成功");
//smt.close();
ppst.close();
conn.close();
out.close();
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
网友评论