1、创建数据库连接类DBConn.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
|
package com.xju.ws;
import java.sql.*;
public class DBConn {
// 存储机器的名称
private String DBDRIVER;
// 存储数据库连接路径
private String DBURL;
// 数据库用户名称
private String DBUSER;
// 数据库密码
private String DBPASS;
/* 设置连接数据库相关参数 */
public DBConn(){
DBDRIVER = "oracle.jdbc.driver.OracleDriver";
DBURL = "jdbc:oracle:thin:@10.238.208.33:1521:XjMobileGIS";
DBUSER = "用户名";
DBPASS = "密码";
}
/* 获取Conncetion对象并返回 */
public Connection getConnection() {
Connection con=null;
try {
Class.forName(DBDRIVER); // 加载Jdbc驱动程序
con = DriverManager.getConnection(DBURL,DBUSER,DBPASS);
}
catch (Exception e) {
e.printStackTrace();
}
return con;
}
} |
2、创建业务实现类GetTokenImpl.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
package com.xju.ws;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
public class GetTokenImpl {
public String[] getResult(String usr, String pwd) {
String[] str = new String[4];
Connection connection = null;
PreparedStatement ps = null;
ResultSet rs = null;
String sql = "select tb_user.selectmodel as selecttype,tb_user.domain as domain,"
+ "tb_authority.username as username,tb_authority.upassword as upassword from tb_user,"
+ "tb_authority where tb_user.selectarea= tb_authority.statename and "
+ "tb_user.selectservice= tb_authority.servicename and tb_user.userid=? and tb_user.userpwd=?";
DBConn dbcon = new DBConn();
connection = dbcon.getConnection();
try {
ps = connection.prepareStatement(sql);
ps.setString(1, usr);
ps.setString(2, pwd);
rs = ps.executeQuery();
if (rs.next()) {
str[0] = rs.getString("selecttype");
str[1] = rs.getString("domain");
str[2] = rs.getString("username");
str[3] = rs.getString("upassword");
} else {
str[0] = "";
str[1] = "";
str[2] = "";
str[3] = "";
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
} finally {
closeResultSet(rs);
closeStatement(ps);
closeConnection(connection);
}
return str;
}
public void closeStatement(PreparedStatement ps) {
if (ps != null) {
try {
ps.close();
ps = null;
} catch (SQLException sqle) {
sqle.printStackTrace();
}
}
}
public void closeResultSet(ResultSet rs) {
if (rs != null) {
try {
rs.close();
rs = null;
} catch (SQLException sqle) {
sqle.printStackTrace();
}
}
}
public void closeConnection(Connection connection) {
try {
if (connection != null && !connection.isClosed()) {
connection.close();
connection = null;
}
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
} |
3、创建Token获取类GetToken.java
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
|
package com.xju.ws;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.NameValuePair;
import org.apache.http.client.ClientProtocolException;
import org.apache.http.client.HttpClient;
import org.apache.http.client.entity.UrlEncodedFormEntity;
import org.apache.http.client.methods.HttpPost;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.message.BasicNameValuePair;
import org.apache.http.util.EntityUtils;
public class GetToken {
public String queryToken(String usr, String pwd) {
String[] str = new String[4];
// GetViewService test=new GetViewService();
GetTokenImpl tokenPara = new GetTokenImpl();
str = tokenPara.getResult(usr, pwd);
// str[0]服务类型：存储服务类型Client/Server
// str[1]服务网址：http://10.236.23.2/mapsercer
// str[2]后台用户名
// str[3]后台密码
// 存储令牌环
String agsToken = "";
String referer_ip = "";
// 创建一个http客户端
HttpClient client = new DefaultHttpClient();
// 创建一个POST请求
HttpPost request = new HttpPost(
"http://10.238.208.34/arcgis/admin/generateToken");
// 设置HTTP POST请求参数必须用NameValuePair
List<NameValuePair> params = new ArrayList<NameValuePair>();
if (str[0].equals("Server")) {
referer_ip = str[1];
params.add(new BasicNameValuePair("client", "referer"));
params.add(new BasicNameValuePair("referer", referer_ip));
params.add(new BasicNameValuePair("expiration", "1440"));
} else {
referer_ip = str[1];
params.add(new BasicNameValuePair("client", "ip"));
params.add(new BasicNameValuePair("ip", referer_ip));
params.add(new BasicNameValuePair("expiration", "480"));
}
params.add(new BasicNameValuePair("username", str[2]));
params.add(new BasicNameValuePair("password", str[3]));
params.add(new BasicNameValuePair("f", "json"));
// 设置http Post请求参数
try {
HttpEntity entity = new UrlEncodedFormEntity(params);
request.setEntity(entity);
HttpResponse response = client.execute(request);
if (response.getStatusLine().getStatusCode() == 200) {// 如果状态码为200,就是正常返回
String result = EntityUtils.toString(response.getEntity());
result.replace("\n", "").replace("\r", "").replace("\t", "");
String[] splitInfos = result.split("\"");
if (splitInfos != null && splitInfos.length > 2) {
if (splitInfos[3].length() > 15
&& splitInfos[1].trim().equals("token")) {
agsToken = splitInfos[3].trim();
}
}
}
} catch (ClientProtocolException e) {
e.printStackTrace();
// 进行处理操作
} catch (IOException e) {
// 进行处理操作
}
return agsToken;
}
} |
备注：Client模式Token有效期为8小时，Server模式Token有效期为24小时。
4、由下向上模式基于GetToken.java类创建Web Server
调用地址：http://10.238.208.34:80/GetTokenService/GetTokenPort?WSDL
（1）Java调用方式关键代码
|
1
2
3
|
GetTokenService service = new GetTokenService();
GetTokenDelegate delegate = service.getGetTokenPort();String token=delegate.queryToken("username", "123456");
|
（2）C#调用代码
|
1
2
3
|
--添加Web引用，Web引用名为：TokenServiceTokenService.GetTokenService service = new TokenService.GetTokenService();
string token = service.queryToken("username", "123456");
|