您的位置:首页 > 编程语言 > Java开发

hessian 在spring中的使用 (bean 如 Dao无法注入的问题)

2017-03-21 14:57 811 查看
背景

由于项目中使用了dubbo(消费者),而dubbo的服务提供方有严格的IP和网络环境限制,导致项目只能在生产环境上启动运行,本地都无法启动测试 。 而且更换生产环境服务器后又得重新申请调用dubbo服务所需的网络环境,时间周期较长 。因此将dubbo消费服务从项目抽离出来成单独的接口系统 。而此接口系统与原项目间采用hessian通信 。

解决问题:由于低级的配置错误,导致hessain接口实现类无法通过注解注入spring bean。 搜索发现有很多人有这个问题,应该是照搬网上配置示例导致。

引入 jar包

<dependency>
<groupId>com.caucho</groupId>
<artifactId>hessian</artifactId>
<version>4.0.38</version>
<scope>compile</scope>
</dependency>


服务端 web.xml 配置

<?xml version="1.0" encoding="UTF-8"?>
<web-app xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns="http://java.sun.com/xml/ns/javaee" xsi:schemaLocation="http://java.sun.com/xml/ns/javaee http://java.sun.com/xml/ns/javaee/web-app_2_5.xsd" id="WebApp_ID" version="2.5">
<display-name>serve-hessian</display-name>

<context-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath*:applicationContext.xml</param-value>
</context-param>
<listener>
<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>
</listener>
<listener>
<listener-class>org.springframework.web.util.IntrospectorCleanupListener</listener-class>
</listener>
<listener>
<listener-class>org.springframework.web.context.request.RequestContextListener</listener-class>
</listener>

<filter>
<filter-name>encodingFilter</filter-name>
<filter-class>org.springframework.web.filter.CharacterEncodingFilter</filter-class>
<init-param>
<param-name>encoding</param-name>
<param-value>utf-8</param-value>
</init-param>
</filter>
<filter-mapping>
<filter-name>encodingFilter</filter-name>
<url-pattern>/*</url-pattern>
</filter-mapping>
<servlet>
<servlet-name>hessian</servlet-name>
<servlet-class>org.springframework.web.servlet.DispatcherServlet</servlet-class>
<init-param>
<param-name>contextConfigLocation</param-name>
<param-value>classpath*:hessian-servlet.xml</param-value>
</init-param>
<load-on-startup>1</load-on-startup>
</servlet>
<servlet-mapping>
<servlet-name>hessian</servlet-name>
<url-pattern>/hessian/*</url-pattern>
</servlet-mapping>
<welcome-file-list>
<welcome-file>index.html</welcome-file>
</welcome-file-list>

</web-app>


classpath下新建hessian-servlet.xml ,注意这里不要定义 bean id ="" ,否则会导致hessain接口实现类中通过注解注入spring 中的bean 如 Dao时无法注入,出现null 异常

正确配置:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd"> <bean name="/bizBusTradeOrder" class="org.springframework.remoting.caucho.HessianServiceExporter">
<property name="service" ref="isaleBusTradeOrderInboundServiceImpl" />
<property name="serviceInterface" value="com.toltech.serve.service.dubbo.IsaleBusTradeOrderInboundService" />
</bean>
</beans>


错误配置(不需要配置bean id="",因为此实现类直接在class中用注解配置,交由spring管理。):

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.2.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.2.xsd"> 
<!--不需要配置  <bean id="isaleBusTradeOrderInboundServiceImpl" class="com.toltech.serve.service.impl.dubbo.IsaleBusTradeOrderInboundServiceImpl"></bean> -->
<bean name="/bizBusTradeOrder" class="org.springframework.remoting.caucho.HessianServiceExporter">
<property name="service" ref="isaleBusTradeOrderInboundServiceImpl" />
<property name="serviceInterface" value="com.toltech.serve.service.dubbo.IsaleBusTradeOrderInboundService" />
</bean>
</beans>


接口实现类(通过 @Service 注解交由spring管理,通过@Resource 注入dubbo服务)

@Service
public class IsaleBusTradeOrderInboundServiceImpl implements IsaleBusTradeOrderInboundService{

@Resource
private BizBusTradeOrderInboundService bizBusTradeOrderInboundService;

@Resource
private RouteService routeService;

public  InboundResponseResult<Map<String, String>> createBizBusOrder(BizBusTradeOrderDto bizbustradeorderdto){
return bizBusTradeOrderInboundService.createBizBusOrder(bizbustradeorderdto);
}

public  InboundResponseResult<Map<String, String>> verifyItvOrder(BizBusTradeOrderDto bizbustradeorderdto){
return bizBusTradeOrderInboundService.verifyItvOrder(bizbustradeorderdto);
}

public  String route(String s, String s1){
return routeService.route(s, s1);
}
}


dubbo 配置(消费者)

<dubbo:reference id="bizBusTradeOrderInboundService" interface="com.**.inbound.service.BizBusTradeOrderInboundService"  version="1.0">
<dubbo:method name="verifyItvOrder" servicecode="33.1001.verifyItvOrder" timeout="30000"/>
<dubbo:method name="createBizBusOrder" servicecode="33.1001.createBizBusOrder" timeout="30000"/>
</dubbo:reference>

<dubbo:reference id="routeService" interface="com.**.RouteService"  version="1.0">
<dubbo:method name="route" servicecode="33.1001.route" timeout="30000"/>
</dubbo:reference>


客户端调用(调用地址 http://localhost:8082/serve-hession/hessian/bizBusTradeOrder )

private IsaleBusTradeOrderInboundService bizBusTradeOrderInboundService;

public IsaleBusTradeOrderInboundService getBizBusTradeOrderInboundService(){
try {
if(bizBusTradeOrderInboundService == null){
String url ="http://localhost:8082/serve-hession/hessian/bizBusTradeOrder";
HessianProxyFactory factory = new HessianProxyFactory();
bizBusTradeOrderInboundService = (IsaleBusTradeOrderInboundService) factory.create(
IsaleBusTradeOrderInboundService.class, url);
}
} catch (Exception e) {
e.printStackTrace();
}
return bizBusTradeOrderInboundService;
}

public  InboundResponseResult<Map<String, String>> createBizBusOrder(BizBusTradeOrderDto bizbustradeorderdto){
if(getBizBusTradeOrderInboundService() != null){
return getBizBusTradeOrderInboundService().createBizBusOrder(bizbustradeorderdto);
}
return null;
}

public  InboundResponseResult<Map<String, String>> verifyItvOrder(BizBusTradeOrderDto bizbustradeorderdto){
if(getBizBusTradeOrderInboundService() != null){
return getBizBusTradeOrderInboundService().verifyItvOrder(bizbustradeorderdto);
}
return null;
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息