JAX-WS в Java: мощный инструмент для создания SOAP веб-сервисов

import javax.jws.WebService;
import javax.jws.WebMethod;
import javax.jws.WebParam;

@WebService(name = "ProductCatalog", targetNamespace = "http://products.example.org/")
public interface ProductCatalogService {

@WebMethod(operationName = "findProductById")
Product getProduct(@WebParam(name = "productId") String id);

@WebMethod
List<Product> searchProducts(@WebParam(name = "keywords") String keywords);

@WebMethod
boolean addProduct(@WebParam(name = "product") Product product);

@WebMethod
boolean updateProduct(@WebParam(name = "product") Product product);
}

import javax.jws.WebService;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;

@WebService(
serviceName = "ProductCatalogService",
portName = "ProductCatalogPort",
endpointInterface = "org.example.products.ProductCatalogService",
targetNamespace = "http://products.example.org/"
)
public class ProductCatalogServiceImpl implements ProductCatalogService {

private Map<String, Product> products = new HashMap<>();

@Override
public Product getProduct(String id) {
return products.get(id);
}

@Override
public List<Product> searchProducts(String keywords) {
if (keywords == null || keywords.trim().isEmpty()) {
return new ArrayList<>(products.values());
}

String[] terms = keywords.toLowerCase().split("\\s+");

return products.values().stream()
.filter(p -> matchesSearch(p, terms))
.collect(Collectors.toList());
}

private boolean matchesSearch(Product p, String[] terms) {
String productText = (p.getName() + " " + p.getDescription()).toLowerCase();
for (String term : terms) {
if (productText.contains(term)) {
return true;
}
}
return false;
}

@Override
public boolean addProduct(Product product) {
if (products.containsKey(product.getId())) {
return false;
}
products.put(product.getId(), product);
return true;
}

@Override
public boolean updateProduct(Product product) {
if (!products.containsKey(product.getId())) {
return false;
}
products.put(product.getId(), product);
return true;
}
}

import javax.xml.bind.annotation.XmlAccessType;
import javax.xml.bind.annotation.XmlAccessorType;
import javax.xml.bind.annotation.XmlElement;
import javax.xml.bind.annotation.XmlType;

@XmlAccessorType(XmlAccessType.FIELD)
@XmlType(name = "Product", propOrder = {
"id",
"name",
"description",
"price",
"stockQuantity"
})
public class Product {

@XmlElement(required = true)
private String id;

@XmlElement(required = true)
private String name;

@XmlElement
private String description;

@XmlElement
private double price;

@XmlElement
private int stockQuantity;

// Геттеры и сеттеры
public String getId() { return id; }
public void setId(String id) { this.id = id; }

public String getName() { return name; }
public void setName(String name) { this.name = name; }

public String getDescription() { return description; }
public void setDescription(String description) { this.description = description; }

public double getPrice() { return price; }
public void setPrice(double price) { this.price = price; }

public int getStockQuantity() { return stockQuantity; }
public void setStockQuantity(int stockQuantity) { this.stockQuantity = stockQuantity; }
}

import javax.xml.ws.Endpoint;

public class ProductCatalogPublisher {
public static void main(String[] args) {
// Создаем экземпляр нашей реализации сервиса
ProductCatalogServiceImpl catalogService = new ProductCatalogServiceImpl();

// Публикуем сервис по указанному адресу
String address = "http://localhost:8080/productcatalog";
Endpoint endpoint = Endpoint.publish(address, catalogService);

System.out.println("Service published at: " + address);
System.out.println("WSDL available at: " + address + "?wsdl");

// Для остановки сервиса в консольном приложении
System.out.println("Press any key to stop the service...");
try {
System.in.read();
} catch (Exception e) {
e.printStackTrace();
}

endpoint.stop();
System.out.println("Service stopped.");
}
}

myservice.war/
├── META-INF/
│ └── MANIFEST.MF
├── WEB-INF/
│ ├── web.xml
│ ├── classes/
│ │ └── org/
│ │ └── example/
│ │ ├── products/
│ │ │ ├── Product.class
│ │ │ ├── ProductCatalogService.class
│ │ │ └── ProductCatalogServiceImpl.class
│ │ └── ... (другие классы)
│ └── lib/
│ └── ... (зависимости, если не предоставляются сервером)
└── ... (статические ресурсы, если есть)

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns="http://xmlns.jcp.org/xml/ns/javaee"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/javaee http://xmlns.jcp.org/xml/ns/javaee/web-app_4_0.xsd"
version="4.0">
<display-name>Product Catalog Service</display-name>

<listener>
<listener-class>com.sun.xml.ws.transport.http.servlet.WSServletContextListener</listener-class>
</listener>

<servlet>
<servlet-name>ProductCatalogService</servlet-name>
<servlet-class>com.sun.xml.ws.transport.http.servlet.WSServlet</servlet-class>
<load-on-startup>1</load-on-startup>
</servlet>

<servlet-mapping>
<servlet-name>ProductCatalogService</servlet-name>
<url-pattern>/productcatalog</url-pattern>
</servlet-mapping>
</web-app>

<?xml version="1.0" encoding="UTF-8"?>
<endpoints xmlns="http://java.sun.com/xml/ns/jax-ws/ri/runtime" version="2.0">
<endpoint
name="ProductCatalogService"
implementation="org.example.products.ProductCatalogServiceImpl"
url-pattern="/productcatalog"
/>
</endpoints>

<!-- pom.xml (фрагмент) -->
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-spring-boot-starter-jaxws</artifactId>
<version>3.5.0</version>
</dependency>

// WebServiceConfig.java
@Configuration
@EnableWs
public class WebServiceConfig {

@Bean
public Endpoint productCatalogEndpoint() {
EndpointImpl endpoint = new EndpointImpl(
bus, new ProductCatalogServiceImpl());
endpoint.publish("/productcatalog");
return endpoint;
}
}

@Test
public void testGetProduct() {
// Создаем клиента веб-сервиса
URL wsdlUrl = new URL("http://localhost:8080/productcatalog?wsdl");
QName serviceName = new QName("http://products.example.org/", "ProductCatalogService");

ProductCatalogService service = new ProductCatalogService(wsdlUrl, serviceName);
ProductCatalog port = service.getProductCatalogPort();

// Подготавливаем тестовые данные
Product testProduct = new Product();
testProduct.setId("test123");
testProduct.setName("Test Product");
testProduct.setPrice(19.99);

// Добавляем продукт и проверяем результат
boolean addResult = port.addProduct(testProduct);
assertTrue("Failed to add product", addResult);

// Получаем продукт и проверяем данные
Product retrievedProduct = port.getProduct("test123");
assertNotNull("Product not found", retrievedProduct);
assertEquals("Product ID mismatch", "test123", retrievedProduct.getId());
assertEquals("Product name mismatch", "Test Product", retrievedProduct.getName());
assertEquals("Product price mismatch", 19.99, retrievedProduct.getPrice(), 0.001);
}

wsimport -keep -p org.example.client http://localhost:8080/productcatalog?wsdl

// Использование сгенерированных классов
import org.example.client.*;

public class ProductCatalogClient {
public static void main(String[] args) {
// Создание сервиса
ProductCatalogService service = new ProductCatalogService();

// Получение порта для доступа к операциям
ProductCatalog catalog = service.getProductCatalogPort();

// Вызов операции сервиса
Product product = catalog.getProduct("123");
System.out.println("Product name: " + product.getName());

// Поиск продуктов
List<Product> searchResults = catalog.searchProducts("laptop");
System.out.println("Found " + searchResults.size() + " products");

// Добавление нового продукта
Product newProduct = new Product();
newProduct.setId("456");
newProduct.setName("New Smartphone");
newProduct.setDescription("Latest model with advanced features");
newProduct.setPrice(599.99);
newProduct.setStockQuantity(100);

boolean success = catalog.addProduct(newProduct);
System.out.println("Product added: " + success);
}
}

import javax.xml.namespace.QName;
import javax.xml.ws.Service;
import java.net.URL;

public class DynamicClient {
public static void main(String[] args) throws Exception {
URL wsdlUrl = new URL("http://localhost:8080/productcatalog?wsdl");

// QName для сервиса и порта
QName serviceQName = new QName("http://products.example.org/", "ProductCatalogService");
QName portQName = new QName("http://products.example.org/", "ProductCatalogPort");

// Создание сервиса
Service service = Service.create(wsdlUrl, serviceQName);

// Получение прокси-объекта для интерфейса
ProductCatalogService catalog = service.getPort(portQName, 
ProductCatalogService.class);

// Теперь можно вызывать методы
Product product = catalog.getProduct("123");
System.out.println("Product: " + product.getName());
}
}

import javax.xml.namespace.QName;
import javax.xml.soap.*;
import javax.xml.ws.Dispatch;
import javax.xml.ws.Service;
import javax.xml.ws.soap.SOAPBinding;
import java.net.URL;

public class LowLevelClient {
public static void main(String[] args) throws Exception {
// Настройка сервиса
URL wsdlUrl = new URL("http://localhost:8080/productcatalog?wsdl");
QName serviceQName = new QName("http://products.example.org/", "ProductCatalogService");
QName portQName = new QName("http://products.example.org/", "ProductCatalogPort");

Service service = Service.create(wsdlUrl, serviceQName);

// Создание Dispatch для работы с SOAP-сообщениями
Dispatch<SOAPMessage> dispatch = service.createDispatch(
portQName, SOAPMessage.class, Service.Mode.MESSAGE);

// Создание SOAP-сообщения
MessageFactory factory = MessageFactory.newInstance(SOAPConstants.SOAP_1_2_PROTOCOL);
SOAPMessage message = factory.createMessage();
SOAPPart part = message.getSOAPPart();
SOAPEnvelope envelope = part.getEnvelope();
SOAPBody body = envelope.getBody();

// Создание элемента запроса
QName getProductQName = new QName("http://products.example.org/", "findProductById");
SOAPElement operation = body.addChildElement(getProductQName);

// Добавление параметра
QName productIdQName = new QName("productId");
SOAPElement param = operation.addChildElement(productIdQName);
param.addTextNode("123");

// Отправка сообщения и получение ответа
SOAPMessage response = dispatch.invoke(message);

// Обработка ответа
SOAPBody responseBody = response.getSOAPBody();

// Извлечение данных из ответа
// ...

System.out.println("Response received.");
}
}

@Configuration
public class WebServiceConfig {

@Bean
public Jaxb2Marshaller marshaller() {
Jaxb2Marshaller marshaller = new Jaxb2Marshaller();
marshaller.setContextPath("org.example.client");
return marshaller;
}

@Bean
public ProductCatalogClient productCatalogClient(Jaxb2Marshaller marshaller) {
ProductCatalogClient client = new ProductCatalogClient();
client.setDefaultUri("http://localhost:8080/productcatalog");
client.setMarshaller(marshaller);
client.setUnmarshaller(marshaller);
return client;
}
}

public class ProductCatalogClient extends WebServiceGatewaySupport {

public Product getProduct(String id) {
GetProductRequest request = new GetProductRequest();
request.setProductId(id);

GetProductResponse response = (GetProductResponse) getWebServiceTemplate()
.marshalSendAndReceive(request);

return response.getProduct();
}

// Другие методы для работы с сервисом
}

@WebService
public interface ERPIntegrationService {
@WebMethod
OrderStatus submitOrder(@WebParam(name = "order") PurchaseOrder order);

@WebMethod
InventoryStatus checkInventory(@WebParam(name = "productId") String productId);

@WebMethod
CustomerInfo getCustomerDetails(@WebParam(name = "customerId") String customerId);
}

// Реализация, которая взаимодействует с ERP через проприетарный API
@WebService(endpointInterface = "com.example.erp.ERPIntegrationService")
public class ERPIntegrationServiceImpl implements ERPIntegrationService {
private ERPConnector erpConnector;

public ERPIntegrationServiceImpl() {
this.erpConnector = new ERPConnector("config/erp-connection.xml");
}

@Override
public OrderStatus submitOrder(PurchaseOrder order) {
// Преобразование в формат ERP
com.erp.vendor.Order erpOrder = convertToERPOrder(order);

// Отправка в ERP
String erpReference = erpConnector.submitOrder(erpOrder);

// Возврат статуса
OrderStatus status = new OrderStatus();
status.setAccepted(true);
status.setOrderReference(erpReference);
status.setEstimatedDelivery(calculateDeliveryDate());

return status;
}

// Другие методы...
}

// Настройка безопасности на стороне сервера
@WebService
@SecurityDomain("other")
@RolesAllowed({"admin", "manager"})
public class SecureFinancialService implements FinancialOperations {

@WebMethod
@RolesAllowed("admin")
public TransactionResult transferFunds(
@WebParam(name = "sourceAccount") String sourceAccount,
@WebParam(name = "targetAccount") String targetAccount,
@WebParam(name = "amount") BigDecimal amount) {
// Логика перевода средств
// ...
}

@WebMethod
@RolesAllowed({"admin", "manager"})
public AccountBalance checkBalance(
@WebParam(name = "accountNumber") String accountNumber) {
// Проверка баланса
// ...
}
}

// Настройка клиента с безопасностью
public class SecureClient {
public static void main(String[] args) throws Exception {
// Создание фабрики контекста безопасности
LoginContext lc = new LoginContext("client-login", new UsernamePasswordCallbackHandler("admin", "password"));
lc.login();

try {
Subject.doAs(lc.getSubject(), new PrivilegedExceptionAction<Void>() {
public Void run() throws Exception {
// Создание клиента веб-сервиса
URL wsdlUrl = new URL("https://secure-server:8443/financial?wsdl");
FinancialService service = new FinancialService(wsdlUrl);
FinancialOperations port = service.getFinancialOperationsPort();

// Настройка SSL
BindingProvider bp = (BindingProvider) port;
bp.getRequestContext().put(BindingProvider.ENDPOINT_ADDRESS_PROPERTY,
"https://secure-server:8443/financial");

// Вызов защищенного метода
AccountBalance balance = port.checkBalance("1234567890");
System.out.println("Balance: " + balance.getAmount());

return null;
}
});
} finally {
lc.logout();
}
}
}

// Клиентский код для асинхронного вызова
public class AsyncClient {
public static void main(String[] args) throws Exception {
URL wsdlUrl = new URL("http://localhost:8080/reports?wsdl");
ReportService service = new ReportService(wsdlUrl);

// Получение порта
ReportGenerator asyncPort = service.getReportGeneratorPort();

// Создание обработчика асинхронного ответа
AsyncHandler<GenerateReportResponse> handler = new AsyncHandler<GenerateReportResponse>() {
@Override
public void handleResponse(Response<GenerateReportResponse> res) {
try {
GenerateReportResponse response = res.get();
Report report = response.getReturn();
System.out.println("Report received asynchronously: " + report.getTitle());
// Обработка отчета
} catch (Exception e) {
e.printStackTrace();
}
}
};

// Асинхронный вызов с обработчиком
ReportCriteria criteria = new ReportCriteria();
criteria.setReportType("ANNUAL_SALES");
criteria.setYear(2023);

Future<?> response = asyncPort.generateReportAsync(criteria, handler);

System.out.println("Request sent, continuing with other operations...");

// Продолжение выполнения других задач, пока отчет генерируется
for (int i = 0; i < 5; i++) {
System.out.println("Doing other work...");
Thread.sleep(1000);
}

// Ожидание завершения асинхронной операции (если нужно)
if (!response.isDone()) {
System.out.println("Waiting for report to complete...");
response.get(); // Блокирующий вызов
}
}
}

// Java-сервис, который будет вызываться из .NET
@WebService(targetNamespace = "http://interop.example.org/")
public class InteropService {

@WebMethod
public CustomerData getCustomerById(@WebParam(name = "customerId") String id) {
CustomerData customer = new CustomerData();
customer.setId(id);
customer.setName("John Doe");
customer.setEmail("john.doe@example.com");

return customer;
}

@WebMethod
public ProductDetails[] getCompatibleProducts(
@WebParam(name = "platform") String platform) {
// Возвращаем список продуктов, совместимых с указанной платформой
// ...
}
}

// Класс передачи данных, адаптированный для интероперабельности
@XmlType(namespace = "http://interop.example.org/")
public class CustomerData {
private String id;
private String name;
private String email;

// Стандартные геттеры и сеттеры...
}

// SOAP-обработчик для логирования запросов и ответов
@SoapMessageHandlers({
@SoapMessageHandler(LoggingHandler.class)
})
@WebService(endpointInterface = "com.example.analytics.AnalyticsService")
public class AnalyticsServiceImpl implements AnalyticsService {
// Реализация сервиса...
}

// Реализация обработчика
public class LoggingHandler implements SOAPHandler<SOAPMessageContext> {

@Override
public boolean handleMessage(SOAPMessageContext context) {
Boolean outbound = (Boolean) context.get(MessageContext.MESSAGE_OUTBOUND_PROPERTY);
try {
SOAPMessage message = context.getMessage();

ByteArrayOutputStream out = new ByteArrayOutputStream();
message.writeTo(out);

System.out.println("SOAP " + (outbound ? "Response:" : "Request:"));
System.out.println(out.toString());
} catch (Exception e) {
e.printStackTrace();
}
return true;
}

@Override
public boolean handleFault(SOAPMessageContext context) {
// Логирование ошибок
return true;
}

@Override
public void close(MessageContext context) {
// Освобождение ресурсов
}

@Override
public Set<QName> getHeaders() {
// Заголовки, которые нас интересуют
return null;
}
}