dubbo 学习笔记 -- provider端

服务端的配置文件：    provider.xml

[html] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
5. xsi:schemaLocation="http://www.springframework.org/schema/beans
6. http://www.springframework.org/schema/beans/spring-beans.xsd
7. http://code.alibabatech.com/schema/dubbo
8. http://code.alibabatech.com/schema/dubbo/dubbo.xsd         ">
9. <!-- Application name -->
10. <dubbo:application name="Frame"  />
11. <!-- registry address, used for service to register itself -->
12. <dubbo:registry address="multicast://224.5.6.7:1234" />
13. <!-- expose this service through dubbo protocol, through port 20880 -->
14. <dubbo:protocol name="dubbo" port="20880" />
15. <!-- which service interface do we expose? -->
16. <dubbo:service interface="merchant.shop.service.IHelloService" ref="helloService" />
17. <!-- bean配置 -->
18. <bean id="helloService"
19. class="merchant.shop.service.impl.HelloServiceImpl">
20. </bean>
21. </beans>

此处interface的地址要与consumer端的一致，所以在服务端工程中新建了和客户端工程一样的路径来保存service

spring 配置文件 ： providerApplicationContext.xml

[html] view plain copy

1. <?xml version="1.0" encoding="UTF-8"?>
2. <beans xmlns="http://www.springframework.org/schema/beans"
3. xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4. xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-2.0.xsd">
5. <!-- spring 与 ibatis 衔接 -->
6. <bean id="sqlMapClient" class="org.springframework.orm.ibatis.SqlMapClientFactoryBean">
7. <property name="configLocation" value="provider-sql-map-config.xml"></property>
8. <property name="dataSource" ref="dataSource"/>
9. </bean>
10. <!-- 数据源基本配置 -->
11. <bean id="dataSource"
12. class="org.springframework.jndi.JndiObjectFactoryBean">
13. <property name="jndiName">
14. <value>java:/comp/env/test</value>
15. </property>
16. </bean>
17. <!-- 事务配置 -->
18. <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
19. <property name="dataSource" ref="dataSource"></property>
20. </bean>
21. <!-- 声明式事务管理 -->
22. <bean id="baseTransactionProxy" class="org.springframework.transaction.interceptor.TransactionProxyFactoryBean" abstract="true">
23. <property name="transactionManager" ref="transactionManager"></property>
24. <property name="transactionAttributes">
25. <props>
26. <prop key="add*">PROPAGATION_REQUIRED</prop>
27. <prop key="edit*">PROPAGATION_REQUIRED</prop>
28. <prop key="*">PROPAGATION_REQUIRED,readOnly</prop>
29. </props>
30. </property>
31. </bean>
32. </beans>

服务端需要启动的两个文件如下 ：

[java] view plain copy

1. package com.sitech.comm.dubbo;
2. import org.springframework.context.ApplicationContext;
3. import org.springframework.context.support.ClassPathXmlApplicationContext;
4. public class Provider {
5. public static void init() throws Exception {
6. ClassPathXmlApplicationContext context = new ClassPathXmlApplicationContext(new String[] {"provider.xml"});
7. context.start();
8. singleton();
9. }
10. public static ApplicationContext context = null;
11. public static ApplicationContext singleton() {
12. if (context == null) {
13. context = new ClassPathXmlApplicationContext(new String[] {"providerApplicationContext.xml"});
14. }
15. return context;
16. };
17. }

[java] view plain copy

1. package com.sitech.comm.dubbo;
2. import javax.servlet.ServletException;
3. import javax.servlet.http.HttpServlet;
4. import com.sitech.comm.log.LogWritter;
5. public class ProviderInit extends HttpServlet {
6. public void init() throws ServletException {
7. try {
8. System.out.println("初始化dubbo服务端");
9. Provider.init();
10. } catch (Exception e) {
11. System.out.println("初始化dubbo服务端失败");
12. }
13. }
14. }

web.xml 中增加启动如下 ：

[html] view plain copy

1. <servlet>
2. <servlet-name>ProviderInit</servlet-name>
3. <servlet-class>
4. com.sitech.comm.dubbo.ProviderInit
5. </servlet-class>
6. <load-on-startup>1</load-on-startup>
7. </servlet>

consumer客户端就可以远程调用另一个工程的服务了

这里出问题，一般都是配置文件的问题，如数据库的连接，spring 与 ibatis 衔接