本人也是才开始接触 阿里巴巴的开源分布式框架 dubbo,因为现在微服务框架 spring boot也非常的火,然后结合dubbo的官网搭建这个开发环境。
一、首先 zookeeper作为集群管理服务器,安装和配置在这里就不说了
划分为 4个项目
项目目录如下:
4个项目的依赖关系是:common里面暂时存放的只有user一个实体类,后面陆续会加上其他的公共类,分页,验证等,这个项目不依赖其他的项目,其他3个项目都需要依赖它,所有这个项目需要先打包(相信做个maven项目的人应该都会-----如果对项目有所改动的话,需要先 maven clean,然后再maven install);
第二个需要打包的是 app项目,service和web项目都依赖它,然后再打包service项目,最后web项目。
hlq-commer-common 项目目录:
hlq-commer-app 就是单独的一个service接口,因为只是搭建个环境,就只写了一个service和 一个方法,
service 代码如下:(就是根据用户id获取一个用户的信息)
package com.commer.app.UserService;
import com.commer.app.entity.User;
public interface UserService {
//根据用户id获取用户信息
User selectByPrimaryKey(Integer id);
}
hlq-commer-service 这个项目作为dubbo的一个服务提供者,最重要的就是暴露服务,数据库的连接,mybatis的映射都在这
项目目录:
App类作为dubbo的一个服务启动类(发布服务,连接数据库,指定映射文件),同时加载spring boot的配置文件,
主要代码:
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.ComponentScan.Filter;
import org.springframework.context.annotation.ImportResource;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import com.alibaba.druid.pool.DruidDataSource;
import com.alibaba.dubbo.config.annotation.Service;
@SpringBootApplication
@ComponentScan(basePackages = { "com.commer.app.service.impl" }, includeFilters = { @Filter(classes = { Service.class}) })
@ImportResource(locations = { "classpath:dubboprovider.xml" })
@MapperScan("com.commer.app.mapper")
public class App {
@Bean(initMethod = "init", destroyMethod = "close")
@ConfigurationProperties(prefix = "spring.datasource")
public DataSource dataSource() {
return new DruidDataSource();
}
@Bean
public SqlSessionFactory sqlSessionFactoryBean() throws Exception {
PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(dataSource());
sqlSessionFactoryBean.setMapperLocations(resolver.getResources("classpath*:/mybatis-mapping/*Mapper.xml"));
return sqlSessionFactoryBean.getObject();
}
public static void main(String[] args) throws IOException {
SpringApplication.run(App.class, args);
System.out.println("服务运行中...");
System.in.read();
}
userMapper类(dao 类)
@Component
public interface UserMapper {
int deleteByPrimaryKey(Long id);
int insert(User record);
int insertSelective(User record);
//根据用户id获取用户信息
User selectByPrimaryKey(Integer id);
}