WebService使用介绍(一)

/**
 * 天气查询服务端
 * @author SMN
 * @version V1.0
 */
public class WeatherServer {
    
    public static void main(String[] args) throws IOException {
        //创建socket服务端对象
        ServerSocket serverSocket = new ServerSocket(1234);
        System.out.println("服务端已启动。。。。");
        while(true){
            //监听客户端连接，accept方法为阻塞方法
            Socket socket = serverSocket.accept();
            //获取输入流准备取客户端发送的数据
            DataInputStream dataInputStream =null;
            DataOutputStream dataOutputStream =null;
            try {
                //包括为datainputstream
                dataInputStream = new DataInputStream(socket.getInputStream());
                //读取数据
                String in_data = dataInputStream.readUTF();
                //打印读取的数据
                System.out.println("from client.."+in_data);
                //创建输出流准备输出数据
                dataOutputStream = new DataOutputStream(socket.getOutputStream());
                System.out.println("to client..."+"晴朗");
                dataOutputStream.writeUTF("晴朗");
            } catch (Exception e) {
                e.printStackTrace();
            }finally{
                //释放资源
                if(dataOutputStream!=null){
                    dataOutputStream.close();
                }
                if(dataInputStream!=null){
                    dataInputStream.close();
                }
            }
        }
    }
}

/**
 * 天气查询客户端
 * @author SMN
 * @version V1.0
 */
public class WeatherClient {
    
    public static void main(String[] args) throws UnknownHostException, IOException {
        while(true){
            //socket客户端对象
            Socket socket = null;
            //输出流用于发送数据
            DataOutputStream dataOutputStream = null;
            //输入流用于接收数据
            DataInputStream dataInputStream = null;
            try {
                //创建socket
                socket = new Socket("127.0.0.1", 1234);
                socket.setSoTimeout(10000);//超时时间为10秒，防止服务端处理超时返回数据失败
                //创建输出流准备向服务端发送数据
                dataOutputStream = new DataOutputStream(socket.getOutputStream());
                dataOutputStream.writeUTF("郑州");
                System.out.println("to server...."+"郑州");
                
                //接收服务端发送的数据
                dataInputStream = new DataInputStream(socket.getInputStream());
                String resultString = dataInputStream.readUTF();
                
                System.out.println("from server..."+resultString);
            } catch (Exception e) {
                e.printStackTrace();
            }finally{
                //释放资源
                if(socket!=null){
                    socket.close();
                }
                if(dataOutputStream!=null){
                    dataOutputStream.close();
                }
                if(dataInputStream!=null){
                    dataInputStream.close();
                }
            
            }
        }
    }
}

/**
 * 天气查询服务接口
 * @author SMN
 * @version V1.0
 */
public interface WeatherInterface {
    //天气查询
    public String queryWeather(String cityName);  
}

/**
 * 天气查询服务接口实现类
 * @author SMN
 * @version V1.0
 */
@WebService
public class WeatherInterfaceImpl implements WeatherInterface {

    @Override
    public String queryWeather(String cityName) {
        System.out.println("from client.."+cityName);
        String result = "晴朗";
        System.out.println("to client..."+result);
        return result;
    }
    
    public static void main(String[] args) {
        //发送webservice服务
        Endpoint.publish("http://192.168.1.100:1234/weather", new WeatherInterfaceImpl());
    }
    
}

/**
 * 天气查询客户端
 * @author SMN
 * @version V1.0
 */
public class WeatherClient {
    public static void main(String[] args) {
        //创建服务视图
        WeatherInterfaceImplService weatherInterfaceImplService =new WeatherInterfaceImplService();
        //通过服务视图得到服务端点
        WeatherInterfaceImpl weatherInterfaceImpl= weatherInterfaceImplService.getPort(WeatherInterfaceImpl.class);
        //调用webservice服务方法
        String result = weatherInterfaceImpl.queryWeather("郑州");
        System.out.println(result);
    }
}

/**
 * 使用javax.xml.ws.Service调用webservice服务
 * @author SMN
 * @version V1.0
 */
public class WeatherClient2 {
    public static void main(String[] args) throws MalformedURLException {
        //定义url，参数为wsdl地址
        URL url = new URL("http://192.168.1.100:1234/weather?wsdl");
        //定义qname，第一个参数是命名空间，第二个参数名称是wsdl里边的服务名
        QName qName = new QName("http://impl.sei.jaxws.ws.itcast.cn/", "WeatherInterfaceImplService");
        //创建服务视图
        Service service = Service.create(url, qName);
        //通过服务视图得到服务端点
        WeatherInterfaceImpl weatherInterfaceImpl =service.getPort(WeatherInterfaceImpl.class);
        //调用webservice
        System.out.println(weatherInterfaceImpl.queryWeather("郑州"));
    }
}