Dubbo+Zookeeper分布式部署
2017-11-15 23:19
465 查看
消费端：controller/service
生产端：ServiceImpl/Mapper(Dao)
主要是注意两端层级结构，两边都要有bean,消费端service接口，生产端seviceImpl，其次就是配置文件的xml的区别
生产端：Bean
package com.jk.provide.bean;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
public class TAtyUser implements Serializable{
/**
*
*/
private static final long serialVersionUID = 8526726857563431642L;
private String cId;
private String cLoginid;
private String cName;
private String cPassword;
private String cMail;
private String cIp;
private String cXmjp;
private String cCorp;
private String cDept;
private Integer nValid;
private Short nOrder;
private String usercode;
private String userpost;
private String cZw;
private String cLinkuser;
private Integer nRylx;
private Integer nShowUser;
private Integer nTxl;
private Integer nSfkq;
private String authImage;
public String getcId() {
return cId;
}
public void setcId(String cId) {
this.cId = cId == null ? null : cId.trim();
}
public String getAuthImage() {
return authImage;
}
public void setAuthImage(String authImage) {
this.authImage = authImage;
}
public String getcLoginid() {
return cLoginid;
}
public void setcLoginid(String cLoginid) {
this.cLoginid = cLoginid == null ? null : cLoginid.trim();
}
public String getcName() {
return cName;
}
public void setcName(String cName) {
this.cName = cName == null ? null : cName.trim();
}
public String getcPassword() {
return cPassword;
}
public void setcPassword(String cPassword) {
this.cPassword = cPassword == null ? null : cPassword.trim();
}
public String getcMail() {
return cMail;
}
public void setcMail(String cMail) {
this.cMail = cMail == null ? null : cMail.trim();
}
public String getcIp() {
return cIp;
}
public void setcIp(String cIp) {
this.cIp = cIp == null ? null : cIp.trim();
}
public String getcXmjp() {
return cXmjp;
}
public void setcXmjp(String cXmjp) {
this.cXmjp = cXmjp == null ? null : cXmjp.trim();
}
public String getcCorp() {
return cCorp;
}
public void setcCorp(String cCorp) {
this.cCorp = cCorp == null ? null : cCorp.trim();
}
public String getcDept() {
return cDept;
}
public void setcDept(String cDept) {
this.cDept = cDept == null ? null : cDept.trim();
}
public Short getnOrder() {
return nOrder;
}
public void setnOrder(Short nOrder) {
this.nOrder = nOrder;
}
public String getUsercode() {
return usercode;
}
public void setUsercode(String usercode) {
this.usercode = usercode == null ? null : usercode.trim();
}
public String getUserpost() {
return userpost;
}
public void setUserpost(String userpost) {
this.userpost = userpost == null ? null : userpost.trim();
}
public String getcZw() {
return cZw;
}
public void setcZw(String cZw) {
this.cZw = cZw == null ? null : cZw.trim();
}
public String getcLinkuser() {
return cLinkuser;
}
public void setcLinkuser(String cLinkuser) {
this.cLinkuser = cLinkuser == null ? null : cLinkuser.trim();
}
public Integer getnRylx() {
return nRylx;
}
public void setnRylx(Integer nRylx) {
this.nRylx = nRylx;
}
public Integer getnTxl() {
return nTxl;
}
public void setnTxl(Integer nTxl) {
this.nTxl = nTxl;
}
public Integer getnValid() {
return nValid;
}
public void setnValid(Integer nValid) {
this.nValid = nValid;
}
public Integer getnShowUser() {
return nShowUser;
}
public void setnShowUser(Integer nShowUser) {
this.nShowUser = nShowUser;
}
public Integer getnSfkq() {
return nSfkq;
}
public void setnSfkq(Integer nSfkq) {
this.nSfkq = nSfkq;
}
}
生产端：Mapper
package com.jk.provide.mapper.dao;
import java.util.List;
import com.jk.provide.bean.TAtyUser;
public interface TAtyUserMapper {
List<TAtyUser> getAllUserList();
}
生产端：Mapper.xml
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="com.jk.provide.mapper.dao.TAtyUserMapper" >
<resultMap id="BaseResultMap" type="com.jk.provide.bean.TAtyUser" >
<id column="C_ID" property="cId" jdbcType="VARCHAR" />
<result column="C_LoginID" property="cLoginid" jdbcType="VARCHAR" />
<result column="C_Name" property="cName" jdbcType="VARCHAR" />
<result column="C_Password" property="cPassword" jdbcType="CHAR" />
<result column="C_Mail" property="cMail" jdbcType="VARCHAR" />
<result column="C_IP" property="cIp" jdbcType="VARCHAR" />
<result column="C_XMJP" property="cXmjp" jdbcType="VARCHAR" />
<result column="C_CORP" property="cCorp" jdbcType="VARCHAR" />
<result column="C_DEPT" property="cDept" jdbcType="VARCHAR" />
<result column="N_Valid" property="nValid" jdbcType="TINYINT" />
<result column="N_Order" property="nOrder" jdbcType="SMALLINT" />
<result column="userCode" property="usercode" jdbcType="VARCHAR" />
<result column="userPost" property="userpost" jdbcType="VARCHAR" />
<result column="C_ZW" property="cZw" jdbcType="VARCHAR" />
<result column="C_LINKUSER" property="cLinkuser" jdbcType="VARCHAR" />
<result column="N_RYLX" property="nRylx" jdbcType="INTEGER" />
<result column="N_SHOW_USER" property="nShowUser" jdbcType="TINYINT" />
<result column="N_TXL" property="nTxl" jdbcType="INTEGER" />
<result column="N_SFKQ" property="nSfkq" jdbcType="TINYINT" />
</resultMap>
<sql id="Base_Column_List" >
C_ID, C_LoginID, C_Name, C_Password, C_Mail, C_IP, C_XMJP, C_CORP, C_DEPT, N_Valid,
N_Order, userCode, userPost, C_ZW, C_LINKUSER, N_RYLX, N_SHOW_USER, N_TXL, N_SFKQ
</sql>
<select id="getAllUserList" resultMap="BaseResultMap" >
select
<include refid="Base_Column_List" />
from t_aty_user
</select>
</mapper>
生产端：ServiceImpl
package com.jk.provide.service.impl;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import com.jk.provide.bean.TAtyUser;
import com.jk.provide.mapper.dao.TAtyUserMapper;
import com.jk.provide.service.IUserInfoService;
/**
* @author 作者 尚峰:
* @version 创建时间：2017年11月15日 上午10:14:20
* 类说明
*/
@Service("userservice")
public class UserInfoServiceImpl implements IUserInfoService {
@Autowired
private TAtyUserMapper tAtyUserMapper;
@Override
public List<TAtyUser> getAllUserList() {
return tAtyUserMapper.getAllUserList();
}
@Override
public String testRequest(TAtyUser user) {
System.out.println(user.getcName());
System.out.println(user.getcPassword());
return "success";
}
}
生产端：Service
package com.jk.provide.service;
import java.util.List;
import com.jk.provide.bean.TAtyUser;
/**
* @author 作者 尚峰:
* @version 创建时间：2017年11月15日 上午10:13:41
* 类说明
*/
public interface IUserInfoService {
List<TAtyUser> getAllUserList();
String testRequest(TAtyUser user);
}
生产端：jdbc
#db driver
jdbc.driver=com.mysql.jdbc.Driver
#db url
jdbc.url=jdbc:mysql://localhost:3306/test2?useUnicode=true&characterEncoding=utf-8
#db username
jdbc.username=root
#db password
jdbc.password=root
#db maxActive
jdbc.maxActive=2
#db minIdle
jdbc.minIdle=5
#db maxIdle
jdbc.maxIdle=5
#\u6700\u5927\u5206\u914D\u7684\u5BF9\u8C61\u6570
redis.maxActive=300
#\u6700\u5927\u80FD\u591F\u4FDD\u6301idel\u72B6\u6001\u7684\u5BF9\u8C61\u6570
redis.maxIdle=200
#\u5F53\u6C60\u5185\u6CA1\u6709\u8FD4\u56DE\u5BF9\u8C61\u65F6\uFF0C\u6700\u5927\u7B49\u5F85\u65F6\u95F4
redis.maxWait=1000
#\u5F53\u8C03\u7528borrow Object\u65B9\u6CD5\u65F6\uFF0C\u662F\u5426\u8FDB\u884C\u6709\u6548\u6027\u68C0\u67E5
redis.testOnBorrow=true
#IP
redis.host=127.0.0.1
#Port
redis.port=6379
生产端：Spring-dubbo.properties
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/sch
14ee7
ema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:p="http://www.springframework.org/schema/p"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns:jaxws="http://cxf.apache.org/jaxws"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd" default-autowire="byName">
<!-- 提供方应用名称信息，这个相当于起一个名字，我们dubbo管理页面比较清晰是哪个应用暴露出来的,保持唯一性 -->
<dubbo:application name="dubbo-provide-1705c"></dubbo:application>
<!-- ███使用zookeeper注册中心暴露服务地址███ -->
<dubbo:registry address="zookeeper://192.168.1.121:2181" register="" check="false" subscribe="false" />
<!-- dubbo端口号指定是否启动访问日志，排查线上错误 -->
<dubbo:protocol name="dubbo" port="20881" ></dubbo:protocol>
<dubbo:service interface="com.jk.provide.service.IUserInfoService" ref="userservice"></dubbo:service>
</beans>
生产端：Spring-mybaties.xml
<?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" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:tx="http://www.springframework.org/schema/tx" xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd" > <!-- 开启注解扫描 识别框架搭建过程中的 @service 和 @repository base-package 扫描com.jk包下的所有类 识别类中有关于spring的注解 注解 其实就是在java类当中编写一个标志，能够被java代码所识别，通过该注解的形式，做对应的代码操作 --> <context:component-scan base-package="com.jk"> </context:component-scan> <!-- 不需要扫描service等等 --> <!-- 配置数据源属性文件 spring读取properties文件所用工具类 --> <bean id="propertyConfigurer" class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> <property name="locations"> <list> <value>classpath:jdbc.properties</value> </list> </property> </bean> <!-- 配置数据源 配置数据库连接池 获取数据源 --> <bean id="dataSource" class="org.apache.commons.dbcp.BasicDataSource"> <property name="driverClassName" value="${jdbc.driver}" /> <property name="url" value="${jdbc.url}" /> <property name="username" value="${jdbc.username}" /> <property name="password" value="${jdbc.password}" /> <!--maxActive: 最大连接数量 --> <property name="maxActive" value="${jdbc.maxActive}" /> <!--minIdle: 最小空闲连接 --> <property name="minIdle" value="${jdbc.minIdle}" /> <!--maxIdle: 最大空闲连接 --> <property name="maxIdle" value="${jdbc.maxIdle}" /> </bean> <!-- mybatis的SqlSession的工厂: SqlSessionFactoryBean dataSource:引用数据源 MyBatis定义数据源,同意加载配置 --> <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> <!-- 引入数据配置 方便mybatis获取数据库连接 --> <property name="dataSource" ref="dataSource"></property> <!--mapperLocations mybatis映射文件的扫描路径 扫描识别mybatis的映射文件 --> <property name="mapperLocations" value="classpath:com/jk/**/mapper/*.xml"></property> </bean> <!-- mybatis自动扫描加载Sql映射文件/接口 : MapperScannerConfigurer sqlSessionFactory basePackage:指定sql映射文件/接口所在的包（自动扫描） --> <bean class="org.mybatis.spring.mapper.MapperScannerConfigurer"> <!-- mybatis没有dao层 mybatis的映射接口充当dao层 --> <property name="basePackage" value="com.jk.**.dao" /> <!-- 注入sqlSessionFactory 相当于把Hibernate的sessionFactory注入到HibernateDaoSupport一样 --> <property name="sqlSessionFactoryBeanName" value="sqlSessionFactory" /> </bean> <!-- 配置事务管理器 --> <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager"> <!-- 配置数据源 引入数据库连接池 获取到数数据连接 --> <property name="dataSource" ref="dataSource" /> </bean> <!-- 定义advice,配置传播特性、事务隔离级别、只读事务、回滚策略 --> <tx:advice id="txAdvice" transaction-manager="transactionManager"> <tx:attributes> <tx:method name="add*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="save*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="up*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="del*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="insert*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="set*" propagation="REQUIRED" rollback-for="java.lang.Exception" /> <tx:method name="*" propagation="REQUIRED" read-only="true" /> </tx:attributes> </tx:advice> <!-- 定义那些类使用事务 --> <aop:config> <aop:advisor pointcut="execution(* com.jk.**.service.*.*(..))" advice-ref="txAdvice" /> </aop:config> </beans>
生产端：pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion>
<groupId>com.jk</groupId>
<artifactId>dubbo-provide-1705c</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>dubbo-provide-1705c Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<!-- spring版本号 -->
<spring.version>4.0.0.RELEASE</spring.version>
<!-- mybatis版本号 -->
<mybatis.version>3.2.6</mybatis.version>
<!-- log4j日志文件管理包版本 -->
<slf4j.version>1.7.7</slf4j.version>
<log4j.version>1.2.17</log4j.version>
<shiro.version>1.3.2</shiro.version>
<gson.version>2.7</gson.version>
</properties>
<dependencies>
<!-- 导入dubbo jar包 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<artifactId>spring</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.4</version>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>2.2.1-b03</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.4</version>
<scope>provided</scope>
</dependency>
<!-- end -->
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
<!-- spring鏍稿績鍖? -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>${gson.version}</version>
</dependency>
<!--permission control-->
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-core</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-spring</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-web</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-oxm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- 鍔犲叆POI鏍稿績渚濊禆 -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>3.10-beta2</version>
</dependency>
<!-- 涓篜OI鏀寔Office Open XML -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.10-beta2</version>
</dependency>
<!-- 鏀寔Word鏂囨。鐨勬搷浣? -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>3.10-beta2</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- mybatis鏍稿績鍖? -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>
<!-- mybatis/spring鍖? -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.2.2</version>
</dependency>
<!-- 瀵煎叆java ee jar 鍖? -->
<dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
<scope>provided</scope>
</dependency>
<!-- 瀵煎叆Mysql鏁版嵁搴撻摼鎺ar鍖? -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.30</version>
</dependency>
<!-- 瀵煎叆dbcp鐨刯ar鍖咃紝鐢ㄦ潵鍦╝pplicationContext.xml涓厤缃暟鎹簱 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.2.2</version>
</dependency>
<!-- JSTL鏍囩绫? -->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<!-- 鏃ュ織鏂囦欢绠＄悊鍖? -->
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<!-- 鏍煎紡鍖栧璞★紝鏂逛究杈撳嚭鏃ュ織 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.1.41</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-asl</artifactId>
<version>1.9.13</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.4</version>
</dependency>
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.9</version>
</dependency>
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-security</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-api</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxws</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-bindings-soap</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.0</version>
</dependency>
<dependency>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.17</version>
</dependency>
<!-- redis整合spring框架 -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.4.2.RELEASE</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.6.2</version>
</dependency>
</dependencies>
<build>
<finalName>dubbo-provide-1705c</finalName>
</build>
</project>
消费端 Controller
package com.jk.consumer.controller;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import com.jk.provide.bean.TAtyUser;
import com.jk.provide.service.IUserInfoService;
/**
* @author 作者 尚峰:
* @version 创建时间：2017年11月15日 上午10:59:11
* 类说明
*/
@Controller
public class UserInfoCon {
@Autowired
private IUserInfoService userservice;
@RequestMapping("getAllUserInfo")
public void getAllUserInfo(){
List<TAtyUser> userList= userservice.getAllUserList();
for (TAtyUser tAtyUser : userList) {
System.out.println(tAtyUser.getcName());
}
}
@RequestMapping("testUserLogin")
public void testUserLogin(){
for (int i = 0 ; i < 10 ; i++) {
TAtyUser user=new TAtyUser();
user.setcName("张三"+i);
user.setcPassword("shangfeng"+i);
String su= userservice.testRequest(user);
System.out.println(su);
}
}
}
消费端Bean 同生产端
package com.jk.provide.bean;
import java.io.Serializable;
import java.util.ArrayList;
import java.util.List;
public class TAtyUser implements Serializable{
/**
*
*/
private static final long serialVersionUID = 8526726857563431642L;
private String cId;
private String cLoginid;
private String cName;
private String cPassword;
private String cMail;
private String cIp;
private String cXmjp;
private String cCorp;
private String cDept;
private Integer nValid;
private Short nOrder;
private String usercode;
private String userpost;
private String cZw;
private String cLinkuser;
private Integer nRylx;
private Integer nShowUser;
private Integer nTxl;
private Integer nSfkq;
private String authImage;
public String getcId() {
return cId;
}
public void setcId(String cId) {
this.cId = cId == null ? null : cId.trim();
}
public String getAuthImage() {
return authImage;
}
public void setAuthImage(String authImage) {
this.authImage = authImage;
}
public String getcLoginid() {
return cLoginid;
}
public void setcLoginid(String cLoginid) {
this.cLoginid = cLoginid == null ? null : cLoginid.trim();
}
public String getcName() {
return cName;
}
public void setcName(String cName) {
this.cName = cName == null ? null : cName.trim();
}
public String getcPassword() {
return cPassword;
}
public void setcPassword(String cPassword) {
this.cPassword = cPassword == null ? null : cPassword.trim();
}
public String getcMail() {
return cMail;
}
public void setcMail(String cMail) {
this.cMail = cMail == null ? null : cMail.trim();
}
public String getcIp() {
return cIp;
}
public void setcIp(String cIp) {
this.cIp = cIp == null ? null : cIp.trim();
}
public String getcXmjp() {
return cXmjp;
}
public void setcXmjp(String cXmjp) {
this.cXmjp = cXmjp == null ? null : cXmjp.trim();
}
public String getcCorp() {
return cCorp;
}
public void setcCorp(String cCorp) {
this.cCorp = cCorp == null ? null : cCorp.trim();
}
public String getcDept() {
return cDept;
}
public void setcDept(String cDept) {
this.cDept = cDept == null ? null : cDept.trim();
}
public Short getnOrder() {
return nOrder;
}
public void setnOrder(Short nOrder) {
this.nOrder = nOrder;
}
public String getUsercode() {
return usercode;
}
public void setUsercode(String usercode) {
this.usercode = usercode == null ? null : usercode.trim();
}
public String getUserpost() {
return userpost;
}
public void setUserpost(String userpost) {
this.userpost = userpost == null ? null : userpost.trim();
}
public String getcZw() {
return cZw;
}
public void setcZw(String cZw) {
this.cZw = cZw == null ? null : cZw.trim();
}
public String getcLinkuser() {
return cLinkuser;
}
public void setcLinkuser(String cLinkuser) {
this.cLinkuser = cLinkuser == null ? null : cLinkuser.trim();
}
public Integer getnRylx() {
return nRylx;
}
public void setnRylx(Integer nRylx) {
this.nRylx = nRylx;
}
public Integer getnTxl() {
return nTxl;
}
public void setnTxl(Integer nTxl) {
this.nTxl = nTxl;
}
public Integer getnValid() {
return nValid;
}
public void setnValid(Integer nValid) {
this.nValid = nValid;
}
public Integer getnShowUser() {
return nShowUser;
}
public void setnShowUser(Integer nShowUser) {
this.nShowUser = nShowUser;
}
public Integer getnSfkq() {
return nSfkq;
}
public void setnSfkq(Integer nSfkq) {
this.nSfkq = nSfkq;
}
}消费端 Service接口
package com.jk.provide.service;
import java.util.List;
import com.jk.provide.bean.TAtyUser;
public interface IUserInfoService {
List<TAtyUser> getAllUserList();
String testRequest(TAtyUser user);
}消费端 log4j
#å®ä¹LOGè¾åºçº§å«
log4j.rootLogger=INFO,Console,File
#å®ä¹æ¥å¿è¾åºç®çå°ä¸ºæ§å¶å°
log4j.appender.Console=org.apache.log4j.ConsoleAppender
log4j.appender.Console.Target=System.out
#å¯ä»¥çµæ´»å°æå®æ¥å¿è¾åºæ ¼å¼ï¼ä¸é¢ä¸è¡æ¯æå®å·ä½çæ ¼å¼
log4j.appender.Console.layout = org.apache.log4j.PatternLayout
log4j.appender.Console.layout.ConversionPattern=[%c] - %m%n
#æ件大å°å°è¾¾æå®å°ºå¯¸çæ¶å产çä¸ä¸ªæ°çæ件
log4j.appender.File =org.apache.log4j.RollingFileAppender
#æå®è¾åºç®å½
log4j.appender.File.File = logs/ssm.log
#å®ä¹æ件æ大大å°
log4j.appender.File.MaxFileSize = 10MB
# è¾åºæ以æ¥å¿ï¼å¦ææ¢æDEBUG表示è¾åºDEBUG以ä¸çº§å«æ¥å¿
log4j.appender.File.Threshold = ALL
log4j.appender.File.layout =org.apache.log4j.PatternLayout
log4j.appender.File.layout.ConversionPattern =[%p] [%d{yyyy-MM-ddHH\:mm\:ss}][%c]%m%n
消费端 Spring-dubbo.xml
<?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:p="http://www.springframework.org/schema/p"
xmlns:dubbo="http://code.alibabatech.com/schema/dubbo"
xmlns:jaxws="http://cxf.apache.org/jaxws"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:aop="http://www.springframework.org/schema/aop"
xsi:schemaLocation=" http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.0.xsd http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.0.xsd http://code.alibabatech.com/schema/dubbo http://code.alibabatech.com/schema/dubbo/dubbo.xsd http://cxf.apache.org/jaxws http://cxf.apache.org/schemas/jaxws.xsd http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.0.xsd" default-autowire="byName">
<!-- 消费方应用名称信息，这个相当于起一个名字，我们dubbo管理页面比较清晰是哪个应用调用的,保持唯一性 -->
<dubbo:application name="dubbo-consumer-1705c" />
<!-- ███使用zookeeper注册中心发现暴露的服务地址【2181zookeeper zoo.cfg一致】███ -->
<dubbo:registry address="zookeeper://192.168.1.121:2181" />
<!-- 消费端引用服务：生成远程服务代理，可以和本地bean一样使用demoService，该interface需要与服务端暴露的服务interface保持一致，该id已注入Spring -->
<dubbo:reference id="userservice" interface="com.jk.provide.service.IUserInfoService"></dubbo:reference>
<!-- 生产端配置dubbo服务 消费端的ref属性=生产端的id属性，interface一致
<dubbo:service interface="com.jk.provide.service.IUserInfoService" ref="userservice"></dubbo:service> -->
</beans>
消费端 Spring-mvc。xml
<?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:p="http://www.springframework.org/schema/p"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:mvc="http://www.springframework.org/schema/mvc"
xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.1.xsd http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-3.1.xsd http://www.springframework.org/schema/mvc http://www.springframework.org/schema/mvc/spring-mvc-4.0.xsd"> <!-- 自动扫描该包，使SpringMVC认为包下用了@controller注解的类是控制器 -->
<context:component-scan base-package="com.jk" />
<!--避免IE执行AJAX时，返回JSON出现下载文件 -->
<bean id="mappingJacksonHttpMessageConverter" class="org.springframework.http.converter.json.MappingJacksonHttpMessageConverter">
<property name="supportedMediaTypes">
<list>
<value>text/html;charset=UTF-8</value>
</list>
</property>
</bean>
<!-- 启动SpringMVC的注解功能，完成请求和注解POJO的映射 -->
<bean class="org.springframework.web.servlet.mvc.annotation.AnnotationMethodHandlerAdapter">
<property name="messageConverters">
<list>
<ref bean="mappingJacksonHttpMessageConverter" /> <!-- JSON转换器 -->
</list>
</property>
</bean>
<!-- 定义跳转的文件的前后缀，视图模式配置 -->
<bean
class="org.springframework.web.servlet.view.InternalResourceViewResolver">
<!-- 这里的配置我的理解是自动给后面action的方法return的字符串加上前缀和后缀，变成一个可用的url地址 -->
<property name="prefix" value="/WEB-INF/" />
<property name="suffix" value=".jsp" />
</bean>
<!-- 配置文件上传，如果没有使用文件上传可以不用配置，当然如果不配，那么配置文件中也不必引入上传组件包 -->
<bean id="multipartResolver" class="org.springframework.web.multipart.commons.CommonsMultipartResolver">
<!-- 默认编码 -->
<property name="defaultEncoding" value="utf-8" />
<!-- 文件大小最大值 -->
<property name="maxUploadSize" value="10485760000" />
<!-- 内存中的最大值 -->
<property name="maxInMemorySize" value="40960" />
</bean>
<!-- <mvc:interceptors>
使用bean定义一个Interceptor，直接定义在mvc:interceptors根标签下面的Interceptor将拦截所有的请求
只要是springMVC的访问请求 都会被拦截到
<bean class="com.jk.login.intercetor.LoginInterceptor"/>
</mvc:interceptors> -->
</beans>
消费端 pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> <modelVersion>4.0.0</modelVersion>
<groupId>com.jk</groupId>
<artifactId>dubbo-consumer-1705c</artifactId>
<packaging>war</packaging>
<version>0.0.1-SNAPSHOT</version>
<name>dubbo-consumer-1705c Maven Webapp</name>
<url>http://maven.apache.org</url>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<!-- spring版本号 -->
<spring.version>4.0.0.RELEASE</spring.version>
<!-- mybatis版本号 -->
<mybatis.version>3.2.6</mybatis.version>
<!-- log4j日志文件管理包版本 -->
<slf4j.version>1.7.7</slf4j.version>
<log4j.version>1.2.17</log4j.version>
<shiro.version>1.3.2</shiro.version>
<gson.version>2.7</gson.version>
</properties>
<dependencies>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.5.3</version>
<exclusions>
<exclusion>
<artifactId>spring</artifactId>
<groupId>org.springframework</groupId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>org.javassist</groupId>
<artifactId>javassist</artifactId>
<version>3.18.1-GA</version>
</dependency>
<dependency>
<groupId>org.jboss.netty</groupId>
<artifactId>netty</artifactId>
<version>3.2.9.Final</version>
</dependency>
<dependency>
<groupId>com.101tec</groupId>
<artifactId>zkclient</artifactId>
<version>0.4</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<dependency>
<groupId>javax.servlet.jsp</groupId>
<artifactId>jsp-api</artifactId>
<version>2.2.1-b03</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.2</version>
</dependency>
<dependency>
<groupId>javax.servlet</groupId>
<artifactId>servlet-api</artifactId>
<version>2.4</version>
<scope>provided</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.11</version>
<scope>test</scope>
</dependency>
<!-- spring鏍稿績鍖? -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-core</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>com.google.code.gson</groupId>
<artifactId>gson</artifactId>
<version>${gson.version}</version>
</dependency>
<!--permission control-->
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-core</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-spring</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.apache.shiro</groupId>
<artifactId>shiro-web</artifactId>
<version>${shiro.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-web</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-oxm</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-jdbc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-webmvc</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-aop</artifactId>
<version>${spring.version}</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- 鍔犲叆POI鏍稿績渚濊禆 -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi</artifactId>
<version>3.10-beta2</version>
</dependency>
<!-- 涓篜OI鏀寔Office Open XML -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.10-beta2</version>
</dependency>
<!-- 鏀寔Word鏂囨。鐨勬搷浣? -->
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-scratchpad</artifactId>
<version>3.10-beta2</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring.version}</version>
</dependency>
<!-- mybatis鏍稿績鍖? -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis</artifactId>
<version>${mybatis.version}</version>
</dependency>
<!-- mybatis/spring鍖? -->
<dependency>
<groupId>org.mybatis</groupId>
<artifactId>mybatis-spring</artifactId>
<version>1.2.2</version>
</dependency>
<!-- 瀵煎叆java ee jar 鍖? -->
<dependency>
<groupId>javax</groupId>
<artifactId>javaee-api</artifactId>
<version>7.0</version>
<scope>provided</scope>
</dependency>
<!-- 瀵煎叆Mysql鏁版嵁搴撻摼鎺ar鍖? -->
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.30</version>
</dependency>
<!-- 瀵煎叆dbcp鐨刯ar鍖咃紝鐢ㄦ潵鍦╝pplicationContext.xml涓厤缃暟鎹簱 -->
<dependency>
<groupId>commons-dbcp</groupId>
<artifactId>commons-dbcp</artifactId>
<version>1.2.2</version>
</dependency>
<!-- JSTL鏍囩绫? -->
<dependency>
<groupId>jstl</groupId>
<artifactId>jstl</artifactId>
<version>1.2</version>
</dependency>
<!-- 鏃ュ織鏂囦欢绠＄悊鍖? -->
<!-- log start -->
<dependency>
<groupId>log4j</groupId>
<artifactId>log4j</artifactId>
<version>${log4j.version}</version>
</dependency>
<!-- 鏍煎紡鍖栧璞★紝鏂逛究杈撳嚭鏃ュ織 -->
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>fastjson</artifactId>
<version>1.1.41</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-log4j12</artifactId>
<version>${slf4j.version}</version>
</dependency>
<dependency>
<groupId>org.codehaus.jackson</groupId>
<artifactId>jackson-mapper-asl</artifactId>
<version>1.9.13</version>
</dependency>
<dependency>
<groupId>commons-fileupload</groupId>
<artifactId>commons-fileupload</artifactId>
<version>1.3.1</version>
</dependency>
<dependency>
<groupId>commons-io</groupId>
<artifactId>commons-io</artifactId>
<version>2.4</version>
</dependency>
<dependency>
<groupId>commons-codec</groupId>
<artifactId>commons-codec</artifactId>
<version>1.9</version>
</dependency>
<dependency>
<groupId>dom4j</groupId>
<artifactId>dom4j</artifactId>
<version>1.6.1</version>
</dependency>
<dependency>
<groupId>org.apache.httpcomponents</groupId>
<artifactId>httpclient</artifactId>
<version>4.5.2</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-ws-security</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-api</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-frontend-jaxws</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-bindings-soap</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.apache.cxf</groupId>
<artifactId>cxf-rt-transports-http</artifactId>
<version>2.7.8</version>
</dependency>
<dependency>
<groupId>org.aspectj</groupId>
<artifactId>aspectjweaver</artifactId>
<version>1.8.0</version>
</dependency>
<dependency>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-surefire-plugin</artifactId>
<version>2.17</version>
</dependency>
<!-- redis整合spring框架 -->
<dependency>
<groupId>org.springframework.data</groupId>
<artifactId>spring-data-redis</artifactId>
<version>1.4.2.RELEASE</version>
</dependency>
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.6.2</version>
</dependency>
</dependencies>
<build>
<finalName>dubbo-consumer-1705c</finalName>
</build>
</project>
内容来自用户分享和网络整理，不保证内容的准确性，如有侵权内容，可联系管理员处理 
相关文章推荐
- dubbo+zookeeper的分布式部署
- apache+tomcat+Jfinal 2.2+dubbo2.5.4+zookeeper3.3.6 +redis+druid 分布式部署成功的一点心得（一）
- zookeeper+dubbo分布式环境搭建部署记录
- apache+tomcat+Jfinal 2.2+dubbo2.5.4+zookeeper3.3.6 +redis+druid 分布式(集群)部署成功的一点心得（二）
- springmvc+mybatis+dubbo+zookeeper分布式架构
- springmvc+mybatis+dubbo+zookeeper分布式架构
- 精华【分布式、微服务、云架构、dubbo+zookeeper+springmvc+mybatis+shiro+redis】分布式大型互联网企业架构！
- 分布式编程—Zookeeper部署以及几种经典使用场景
- dubbo+zookeeper 分布式应用的快速入门
- 【Dubbo实战】 Dubbo+Zookeeper+Spring整合应用篇-Dubbo基于Zookeeper实现分布式服务（二）
- springmvc+mybatis+dubbo+zookeeper分布式架构
- （十四）springmvc+mybatis+dubbo+zookeeper分布式架构 整合 - window安装zookeeper注册中心
- 031 分布式中，zookeeper的部署
- zookeeper+springmvc+dubbo分布式技术
- Dubbo学习总结（4）——Dubbo基于Zookeeper实现分布式实例
- JEESZ架构、分布式服务：Dubbo+Zookeeper+Proxy+Restful
- 使用Zookeeper分布式部署PHP应用程序
- 构建 Zookeeper + Dubbo + Spring Boot 的分布式调用项目
- Java集群优化——dubbo+zookeeper构建高可用分布式集群
- window7下部署zookeeper、启动dubbo-admin