搭建WebService开发环境，改进“图片上传”实验
写在前面：
本次实验是在Jsp+servlet+SqlServer实现图片上传、图片详情查看、表格分页实验的基础上进行改进……
(°ー°〃)菜鸟一枚！如有问题欢迎指出！！
结果展示
1、新建两个工程，一个是Webservice的Server端，一个是Webservice的Client端。
2、把原来业务层里的类（方法）通过Webservice发布出来，提供Client调用。
↓ 画了个简陋的图。。凑合看看
Server端
核心代码
ImageDAOImpl.java
package com.bnuz.dao.impl;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import javax.jws.WebService;
import com.bnuz.dao.ImageDAO;
import com.bnuz.javabean.Image;
import com.bnuz.util.DBUtil;
/*
* 这个注解一定要加上！！在ImageDAO中也要加上这个注解
*/
@WebService
public class ImageDAOImpl implements ImageDAO{
private Connection conn;
private PreparedStatement ps;
@Override
public void add(Image image) {
try {
conn = DBUtil.getConn();
ps = conn.prepareStatement("insert into images(title,url) values (?,?)");
ps.setString(1, image.getTitle());
ps.setString(2, image.getImgurl());
ps.execute();
} catch (SQLException e) {
e.printStackTrace();
}
}
@Override
public List<Image> queryAll() {
List<Image> images = new ArrayList<Image>();
try {
conn = DBUtil.getConn();
ps = conn.prepareStatement("select * from images");
ResultSet rs = ps.executeQuery();
while(rs.next()) {
int id = rs.getInt("id");
String title = rs.getString("title");
String url = rs.getString("url");
Image image = new Image(id,title,url);
images.add(image);
}
} catch (SQLException e) {
e.printStackTrace();
}
return images;
}
@Override
public Image query(int id) {
Image image = new Image();
try {
conn = DBUtil.getConn();
ps = conn.prepareStatement("select * from images where id = ?");
ps.setInt(1, id);
ResultSet rs = ps.executeQuery();
while(rs.next()) {
image.setId(id);
image.setTitle(rs.getString("title"));
image.setImgurl(rs.getString("url"));
}
} catch (SQLException e) {
e.printStackTrace();
}
return image;
}
@Override
public List<Image> queryScope(int start, int end) {
List<Image> images = new ArrayList<Image>();
try {
conn = DBUtil.getConn();
ps = conn.prepareStatement("select * from images where id>? and id<?");
ps.setInt(1, start);
ps.setInt(2, end);
ResultSet rs = ps.executeQuery();
while(rs.next()) {
int id = rs.getInt("id");
String title = rs.getString("title");
String url = rs.getString("url");
Image image = new Image(id,title,url);
images.add(image);
}
} catch (SQLException e) {
e.printStackTrace();
}
return images;
}
}
发布服务，Endpoint.publish方法含两个参数：1、服务地址；2、服务实现类
测试发布是否成功
Client端
先在eclipse中创建一个动态Web项目Client
wsimport -s . http://127.0.0.1:8848/images?wsdl
随后在eclipse中refresh一下Client项目，refresh后我们将看到Client项目生成了一个com.bnuz.dao.impl包，接着我们就可以调用Server提供给我们的服务编写Client端的代码了！
上传文件需要用到的jar包 ↓
Add.jsp
<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>图片上传</title>
<style>
.info-div{
margin-top:10px;
}
</style>
</head>
<body>
<form action="upload" method="post" enctype="multipart/form-data">
<div class="info-div">
<label>主题：</label>
<input type="text" name="title">
</div>
<div class="info-div">
<label>图片：</label>
<input type="file" name="uploadImg">
</div>
<div class="info-div">
<input type="submit" value="保存">
</div>
</form>
</body>
</html>
List.jsp
<%@page import="com.bnuz.dao.impl.Image"%>
<%@page import="java.util.List"%>
<%@page import="com.bnuz.dao.impl.ImageDAOImpl"%>
<%@page import="com.bnuz.dao.impl.ImageDAOImplService"%>
<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>图片列表</title>
</head>
<body>
<%
//创建服务视图，视图是从wsdl文件的service标签的name属性获取
ImageDAOImplService iService = new ImageDAOImplService();
//获取服务实现类，实现类从wsdl文件的portType的name属性获取
ImageDAOImpl imageDAOImpl = iService.getPort(ImageDAOImpl.class);
//获取查询方法，从portType的operation标签获取
List<Image> images = imageDAOImpl.queryAll();
int pages = images.size() / 3 + ((images.size() % 3 != 0) ? 1 : 0); //总页数
int start = 0;
List<Image> pageImages = imageDAOImpl.queryScope(0, 4);
if (request.getParameter("page") != null) {
String s = request.getParameter("page");
start = Integer.parseInt(s);
pageImages = imageDAOImpl.queryScope(start * 3 - 3, start * 3 + 1);
}
%>
<a href="Add.jsp">上传图片</a>
<div style="display: flex; height: 30px; margin-top:10px">
<form action="List.jsp?page=<%=start - 1%>" method="post">
<input type="submit" value="上一页">
</form>
<form action="List.jsp" method="post">
<input type="text" name="page"
value="<%=request.getParameter("page")%>" style="width: 50px;">
<input type="submit" value="跳转">
</form>
<br>
<form action="List.jsp?page=<%=start + 1%>" method="post">
<input type="submit" value="下一页">
</form>
<label>一共有<%=images.size()%>条数据，共<%=pages%>页
</label>
</div>
<table border="1" style="text-align: center;">
<tr>
<th style="width: 50px;">id</th>
<th style="width: 150px;">主题</th>
<th style="width: 100px;">图片</th>
<th style="width: 80px;">操作</th>
</tr>
<%
for (Image u : pageImages) {
%>
<tr>
<td><%=u.getId()%></td>
<td><%=u.getTitle()%></td>
<td><img style="width: 80px; height: 50px"
src="<%=u.getImgurl()%>"></img></td>
<td>
<form action="Detail.jsp?id=<%=u.getId()%>" method="post">
<input type="submit" value="查看" name="s">
</form>
</td>
</tr>
<%
}
%>
</table>
</body>
</html>
Detail.jsp
<%@page import="com.bnuz.dao.impl.Image"%>
<%@page import="com.bnuz.dao.impl.ImageDAOImpl"%>
<%@page import="com.bnuz.dao.impl.ImageDAOImplService"%>
<%@ page language="java" contentType="text/html; charset=UTF-8"
pageEncoding="UTF-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>详情页</title>
</head>
<body>
<%
int id = Integer.parseInt(request.getParameter("id"));
ImageDAOImplService iService = new ImageDAOImplService();
ImageDAOImpl imageDAOImpl = iService.getPort(ImageDAOImpl.class);
Image image = imageDAOImpl.query(id);
%>
<div>
<label>主题：</label>
<label><%=image.getTitle()%></label>
</div>
<div>
<label>发布人：YE</label>
</div>
<div>
<label>图片：</label><br>
<img src="<%=image.getImgurl()%>"
style="height: 200px; width: 300px;">
</div>
</body>
</html>
UploadServlet.java
package com.bnuz.servlet;
import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import com.bnuz.dao.impl.Image;
import com.bnuz.dao.impl.ImageDAOImpl;
import com.bnuz.dao.impl.ImageDAOImplService;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
import java.util.List;
import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
/**
* Servlet implementation class UploadServlet
*/
@WebServlet("/UploadServlet")
public class UploadServlet extends HttpServlet {
private static final long serialVersionUID = 1L;
/**
* @see HttpServlet#HttpServlet()
*/
public UploadServlet() {
super();
// TODO Auto-generated constructor stub
}
/**
* @see HttpServlet#doGet(HttpServletRequest request, HttpServletResponse
* response)
*/
protected void doGet(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
// TODO Auto-generated method stub
doPost(request, response);
}
/**
* @see HttpServlet#doPost(HttpServletRequest request, HttpServletResponse
* response)
*/
protected void doPost(HttpServletRequest request, HttpServletResponse response)
throws ServletException, IOException {
response.setContentType("text/html;charset=utf-8");
// 数据库以UTF-8编码解析数据
request.setCharacterEncoding("UTF-8");
Image image = new Image();
ImageDAOImplService iService = new ImageDAOImplService();
ImageDAOImpl imageDAOImpl = iService.getPort(ImageDAOImpl.class);
String name = null;
if (!ServletFileUpload.isMultipartContent(request)) {
throw new RuntimeException("当前请求不支持文件上传");
}
// 为基于磁盘的文件项创建一个FileItem工厂
DiskFileItemFactory factory = new DiskFileItemFactory();
// 设置临时文件的边界值，大于该值时，上传文件会先保存在临时文件中，否则，上传文件将直接写入到内存
// 单位：字节，设置边界值1M，一字节=1024M;
factory.setSizeThreshold(1024 * 1024 * 1);
// 设置文件临时储存
String temppath = this.getServletContext().getRealPath("/temp");
File temp = new File(temppath);
factory.setRepository(temp);
// 创建一个新的文件上传处理程序
ServletFileUpload upload = new ServletFileUpload(factory);
// 设置每一个item的头部字符编码，其可以解决文件名中文乱码问题；
upload.setHeaderEncoding("UTF-8");
// 设置单个文件的最大边界值(这里是2M)
upload.setFileSizeMax(1024 * 1024 * 2);
// 设置一次上传所有文件总和的最大值(对上传多个文件起作用,这里最大为5M)
upload.setSizeMax(1024 * 1024 * 5);
// 解析请求,获取所有的item
try {
//
// 调用ServletFileUpload.parseRequest方法解析request对象，
// 得到一个保存了所有上传内容的List对象。
List<FileItem> items = upload.parseRequest(request);
// 遍历
for (FileItem item : items) {
// 若item为普通表单项
if (item.isFormField()) {
// 获取表单中属性名称
String fieldName = item.getFieldName();
if (fieldName.equals("title")) {
// 获取表单属性的值
name = item.getString("UTF-8");
}
System.out.println(fieldName + "=" + name);
// 若 item为文件表单项
} else {
// 获取文件大小
long size = item.getSize();
// 获取文件类型
String contentType = item.getContentType();
// 获取上传文件原始名字
String fileName = item.getName();
System.out.println("文件大小：" + size);
System.out.println("文件的类型：" + contentType);
// 如果上传的内容不是图片，则跳出循环，不进行处理
if ((!"image/jpeg".equals(contentType)) && (!"image/png".equals(contentType))) {
break;
}
// 获取文件名,处理获取到的上传文件的文件名的路径部分，只保留文件名部分
if (fileName.contains("\\")) {
// 如果包含则截取字符串
fileName = fileName.substring(fileName.lastIndexOf("\\") + 1);
}
// 设置文件名，因为同名的文件会覆盖，所以要修饰文件名，设置毫秒+文件名
fileName = System.currentTimeMillis() + fileName;
System.out.println("文件的名称：" + fileName);
// 获取输入流,其实有上传文件的内容
InputStream inputStream = item.getInputStream();
String path = getServletContext().getRealPath("img/");
System.out.println(path);
File dirFile = new File(path);
if (!dirFile.exists()) {
// 创建多级目录mkdirs()
dirFile.mkdir();
}
// 创建目录文件，将来用于保存上传文件
File file = new File(path, fileName);
// 创建文件输出流
OutputStream os = new FileOutputStream(file);
// 把输入流中的数据写入到输出流
int len = 0;
byte[] buf = new byte[1024];
while ((len = inputStream.read(buf)) != -1) {
os.write(buf, 0, len);
}
// 图片上传到之后的路径
path = "img/" + fileName;
image.setTitle(name);
image.setImgurl(path);
//调用ImageDAOImpl接口的add()方法
imageDAOImpl.add(image);
os.close();
inputStream.close();
item.delete();
}
}
// 上传完毕后回到List.jsp页面
response.sendRedirect("List.jsp");
} catch (FileUploadException e) {
e.printStackTrace();
}
}
}
web.xml
加上↓
<servlet>
<servlet-name>upload</servlet-name>
<servlet-class>com.bnuz.servlet.UploadServlet</servlet-class>
</servlet>
<servlet-mapping>
<servlet-name>upload</servlet-name>
<url-pattern>/upload</url-pattern>
</servlet-mapping>
images.sql
create table images(
id int identity(1,1) primary key,
title varchar(50),
url varchar(255)
);