FreeMarker+URLConnection请求webService接口服务

秒速五厘米 2023-01-13 05:42 164阅读 0赞

*  **1.引入freemark**

<dependency>
    		<groupId>org.freemarker</groupId>
    		<artifactId>freemarker</artifactId>
    		<version>2.3.31</version>
    	</dependency>

*  **2.freemark将文本进行格式化返回格式化之后的文本**

String templateStr = "${a}";
    		Template template = new Template("test", templateStr,
    				new Configuration(Configuration.VERSION_2_3_31));
    		Map<String, Object> map = new HashMap<String, Object>(2);
    		map.put("a", "这是一段测试文本");
    		String temp = FreeMarkerTemplateUtils.processTemplateIntoString(template, map);
    		System.out.println(temp);

*  **3.使用URLconnection访问webService服务**

新建一个Springboot项目引入CXF依赖，发布一个webService服务

<dependency>
    			<groupId>org.apache.cxf</groupId>
    			<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
    			<version>3.4.3</version>
    		</dependency>

新建一个webService接口

@WebService
    public interface TestService { 
    
    	@WebMethod
    	public @WebResult(name = "nameResult") String test(@WebParam(name = "names") String names);
    
    }

新建一个webService实现类，并继承该接口

//targetNamespace 为包名倒写
    @WebService(targetNamespace = "test.service.cxf.demo.example.com")
    @Service
    public class TestServiceImpl implements TestService { 
    
    	@Override
    	public String test(String names) { 
    		return names;
    	}
    
    }

将服务发布

@Configuration
    public class CxfConfig { 
    
    	@Autowired
    	private SpringBus springBus;
    	@Autowired
    	private TestServiceImpl testService;
    
    	@Bean
    	public Endpoint testServiceEndpoint() { 
    		Endpoint endpoint = new EndpointImpl(springBus, testService);
    		endpoint.publish("/test");
    		return endpoint;
    	}
    
    }

访问localhost:8080/services查看接口发布是否成功
    使用URLConnection进行访问webService服务
    	1. 使用soapui获取访问requestBody

![获取responseBody][responseBody]

public static void main(String[] arges){ 
    	String requestBody = "<soapenv:Envelope xmlns:soapenv=\"http://schemas.xmlsoap.org/soap/envelope/\" xmlns:test=\"http://test.service.cxf.demo.example.com/\">"
    						   + "<soapenv:Header/>"
    							   + "<soapenv:Body>"
    							   + "<test:test>"
    							      + "<names>这是一段测试文本</names>"
    							   + "</test:test>"
    							+ "</soapenv:Body>"
    						+ "</soapenv:Envelope>";
    	String urlPath = "http://localhost:8080/services/test";
    	String result = getinfoByScop(urlPath, requestBody);
    }
    
    public static String getinfoByScop(String urlPath, String requestBody) throws Exception { 
    		URL url = new URL(urlPath);
    		HttpURLConnection connection = (HttpURLConnection) url.openConnection();
    		connection.setDoOutput(true);
    		connection.setDoInput(true);
    		connection.setRequestMethod("POST");
    		connection.setRequestProperty("content-type", "text/xml;charset=utf-8");
    
    		OutputStream outputStream = connection.getOutputStream();
    		outputStream.write(requestBody.getBytes());
    		int code = connection.getResponseCode();
    		StringBuffer buffer = new StringBuffer();
    		if (code == 200) { 
    			InputStream inputStream = connection.getInputStream();
    			byte[] bs = new byte[1024];
    			Integer len = 0;
    			while ((len = inputStream.read(bs)) != -1) { 
    				buffer.append(new String(bs, 0, len, "utf-8"));
    			}
    			inputStream.close();
    		}
    		outputStream.close();
    		return buffer.toString();
    	}

**4.将freemark与URLConnection进行整合**

[responseBody]: /images/20221022/ded2e235f7424bcb94eb6cd857cbbe6d.png