webservice系统学习笔记10-使用jax-ws创建基于tomcat类型的容器的ws服务

y23335793

　　1、在web-info目录下新建目录wsdl
　　2、在1步的目录下
　　新建文件user.wsdl








































































































































　　
　　user.xsd的文件内容如下：















































































　　
　　3、修改web.xml






com.sun.xml.ws.transport.http.servlet.WSServletContextListener


UserService
com.sun.xml.ws.transport.http.servlet.WSServlet
   

UserService
/us


　　
4、在web-info下新建文件sun-jaxws.xml







　　5、使用wsimport命令生成服务端的服务接口类
　　6、编写服务端接口类



package cn.edu.zttc.service;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.util.List;
import javax.annotation.Resource;
import javax.jws.WebService;
import javax.xml.namespace.QName;
import javax.xml.stream.XMLStreamException;
import javax.xml.stream.XMLStreamReader;
import javax.xml.stream.events.XMLEvent;
import javax.xml.ws.WebServiceContext;
import javax.xml.ws.soap.MTOM;
import org.zttc.dao.UserDao;
import org.zttc.dao.UserException;
import org.zttc.vo.User;
import com.sun.xml.ws.api.message.Header;
import com.sun.xml.ws.api.message.HeaderList;
import com.sun.xml.ws.developer.JAXWSProperties;

@WebService(endpointInterface="cn.edu.zttc.service.IUserService",
wsdlLocation="WEB-INF/wsdl/user.wsdl",
serviceName="UserService",
portName="UserServicePort",
targetNamespace="http://service.zttc.edu.cn")
@MTOM
public class UserServiceImpl implements IUserService {
private UserDao userDao = UserDao.newInstance();
//注入webservice的上下文对象

    @Resource
private WebServiceContext ctx;

@Override
public void add(User user) throws UserException {
checkRegister();
userDao.add(user);
}
private void checkRegister() throws UserException {
try {
HeaderList headers = (HeaderList)ctx.getMessageContext().get(JAXWSProperties.INBOUND_HEADER_LIST_PROPERTY);
QName qname = new QName("http://service.zttc.edu.cn","licenceInfo");
if(headers==null) throw new UserException("该功能需要进行权限控制");
Header header = headers.get(qname,true);
if(header==null) throw new UserException("该功能需要进行权限控制");
XMLStreamReader xsr = header.readHeader();
User u = x2user(xsr);
User tu = userDao.loadByUsername(u.getUsername());
if(tu==null) throw new UserException("你所使用的用户不是系统的授权用户");
if(!tu.getPassword().equals(u.getPassword()))
throw new UserException("授权用户的密码信息不正确!");
} catch (XMLStreamException e) {
e.printStackTrace();
}
}
private User x2user(XMLStreamReader xsr) throws XMLStreamException {
User u = new User();
while(xsr.hasNext()) {
int event = xsr.next();
if(event==XMLEvent.START_ELEMENT) {
String name = xsr.getName().toString();
if(name.equals("username")) {
u.setUsername(xsr.getElementText());
} else if(name.equals("password")) {
u.setPassword(xsr.getElementText());
} else if(name.equals("nickname")) {
u.setNickname(xsr.getElementText());
}
}
}
return u;
}
@Override
public void delete(String username) throws UserException {
checkRegister();
userDao.delete(username);
}
@Override
public List list() {
return userDao.list();
}
@Override
public User login(String username, String password) throws UserException {
return userDao.login(username, password);
}
@Override
public void upload(byte[] file) {
FileOutputStream fos = null;
System.out.println(file);
try {
fos = new FileOutputStream("d:/webservice/1.jpg");
fos.write(file);
fos.flush();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
try {
fos.close();
} catch (IOException e) {
e.printStackTrace();
}
}
}
}
　　需要导入的jax-ws的jar包如下：

　　
　　这里服务端获取header的信息的方法又多了一个，具体看上面的实现类的代码中的方法checkRegister
　　客户端设置heade的方式还有如下方法：
　　import javax.xml.bind.JAXBContext;
import javax.xml.bind.JAXBElement;
import javax.xml.bind.Marshaller;
import javax.xml.namespace.QName;
import javax.xml.parsers.DocumentBuilderFactory;
import javax.xml.ws.soap.MTOMFeature;
import com.sun.xml.ws.api.message.Headers;
import com.sun.xml.ws.developer.WSBindingProvider;



@Test
public void testAdd() {
try {
//1、将一个对象转换为xml通过JAXB
JAXBContext ctx = JAXBContext.newInstance(LicenceInfo.class);
User ru = new User();
ru.setNickname("超级管理");
ru.setUsername("admin");
ru.setPassword("1232323");
LicenceInfo info = new LicenceInfo();
info.setRegisterUser(ru);
QName name = new QName(ns,"licenceInfo");
JAXBElement jele = new JAXBElement(name,LicenceInfo.class,info);
Marshaller mars = ctx.createMarshaller();
mars.setProperty(Marshaller.JAXB_FRAGMENT,true);
mars.setProperty(Marshaller.JAXB_ENCODING, "UTF-8");
//2、转换为DOM
Document doc = DocumentBuilderFactory.newInstance().newDocumentBuilder().newDocument();
mars.marshal(jele, doc);
//3、通过Headers.create方法完成header的添加
//获取WSBindingProvider
WSBindingProvider wsb = (WSBindingProvider)port;
wsb.setOutboundHeaders(Headers.create(doc.getDocumentElement()));

User u = new User();
u.setNickname("张三");
u.setPassword("123");
u.setUsername("zs");
port.add(u);
}catch(Exception e) {
System.out.println(e.getMessage());
}
}

@Test
public void testUpload() {
try {
byte[] file = FileUtils.readFileToByteArray(new File("d:/kh/img/美女01.jpg"));
port.upload(file);
} catch (IOException e) {
e.printStackTrace();
}
}
　　关于附件的传输可以参考如下文章：https://www.ibm.com/developerworks/cn/webservices/ws-tip-jaxwsrpc5/