springcloud 生产者消费者

父工程：空包建立maven项目，其他都删掉



    4.0.0

    com.wxb
    springcloud
    1.0-SNAPSHOT
    
        springcloue-api
        springcloud-provider-dept-8001
        springcloud-consurmer-dept-80
    
    
    pom

    
        4.12
        1.18.24
        1.2.17
    

    
    
         
            org.springframework.cloud
            spring-cloud-dependencies
            Greenwich.SR1
            pom
            import
        
    
        
            org.springframework.boot
            spring-boot-dependencies
            2.1.4.RELEASE
            pom
            import
        
        
        
            mysql
            mysql-connector-java
            5.1.49
        
        
            com.alibaba
            druid
            1.2.9
        
        
        
            org.mybatis.spring.boot
            mybatis-spring-boot-starter
            1.3.2
        
        
        
            junit
            junit
            ${junit.version}
        
        
        
            org.projectlombok
            lombok
            ${lombok.version}
        
        
        
            log4j
            log4j
            ${log4j.version}
        
        
            ch.qos.logback
            logback-core
            1.2.11

右键父工程新建一个Module项目，如上图操作，创建下面名字springcloud-api（图名字是我不小心打错一个e）不过这不影响

springcloud-api的pom.xml



    
        springcloud
        com.wxb
        1.0-SNAPSHOT
    
    4.0.0
    springcloue-api
    
        
            org.projectlombok
            lombok

springcloud-api实体类

package com.wxb.springcloud.pojo;

import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import java.io.Serializable;
//尽量减少代码，我就用lombook，避免帖子太长
@Data
@NoArgsConstructor
@AllArgsConstructor
@Accessors(chain = true)//开启链式编程
public class Dept implements Serializable  {
    private Long deptno;
    private String dname;
    //这个数据存在哪个数据库的字段~ 微服务，一个服务对应一个数据库，同一个信息存在不同的数据库
    private String db_source;

    public Dept(String dname) {
        this.dname = dname;
    }
}

标题跟上面一样右键new 一个子工程空maven项目springcloud-provider-dept-8001

1.springcloud-provider-dept-8001 的pom.xml



    
        springcloud
        com.wxb
        1.0-SNAPSHOT
    
    4.0.0

    springcloud-provider-dept-8001
    
        
        
            com.wxb
            springcloue-api
            1.0-SNAPSHOT
        
        
        
            junit
            junit
        
        
            mysql
            mysql-connector-java
        
        
            com.alibaba
            druid
        
        
            ch.qos.logback
            logback-core
        
        
            org.mybatis.spring.boot
            mybatis-spring-boot-starter
        
        
        
            org.springframework.boot
            spring-boot-test
        
        
            org.springframework.boot
            spring-boot-starter-web
        
        
        
            org.springframework.boot
            spring-boot-starter-jetty
        
        
        
            org.springframework.boot
            spring-boot-devtools

2.springcloud-provider-dept-8001 的Dao层

用mybatis也叫mapper层

package com.wxb.springcloud.dao;
import com.wxb.springcloud.pojo.Dept;
import org.apache.ibatis.annotations.Mapper;
import org.springframework.stereotype.Repository;
import java.util.List;

@Mapper //有这个注解的接口会在spring中寻找到名字一样的实现类，也就是下面
@Repository //这个注解把接口交给spring管理
public interface DeptDao {
    public Boolean addDept(Dept dept);
    public Dept queryById(Long id);
    public List queryAll();
}

3.springcloud-provider-dept-8001 DeptMapper.xml

mapper实现，或者是Dao的impl都可以，我这里用mapper，id要跟上面的接口的方法名要一致




    
        insert into db01.dept(dname, db_source)
        VALUES (#{dname},DATABASE())
    
    
        select * from dept where deptno=#{deptno}

4.springcloud-provider-dept-8001 的DeptService 接口

package com.wxb.springcloud.service;
import com.wxb.springcloud.pojo.Dept;
import java.util.List;

public interface DeptService {
    public Boolean addDept(Dept dept);
    public Dept queryById(Long id);
    public List queryAll();
}

5.springcloud-provider-dept-8001 的DeptServiceImpl实现类

package com.wxb.springcloud.service;

import com.wxb.springcloud.dao.DeptDao;
import com.wxb.springcloud.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.util.List;
@Service
public class DeptServiceImpl implements DeptService {
    @Autowired
    private DeptDao deptDao;

    public Boolean addDept(Dept dept) {
        return deptDao.addDept(dept);
    }

    public Dept queryById(Long id) {
        return deptDao.queryById(id);
    }

    public List queryAll() {
        return deptDao.queryAll();
    }
}

6.springcloud-provider-dept-8001 的 DeptController

package com.wxb.springcloud.controller;

import com.wxb.springcloud.pojo.Dept;
import com.wxb.springcloud.service.DeptService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import java.util.List;

//提供Restful服务
@RestController
public class DeptController {
    @Autowired
    private DeptService deptService;

    @RequestMapping("/dept/add")
    public Boolean addDept(Dept dept){
        System.out.println(dept.toString());
        return deptService.addDept(dept);
    }
    @GetMapping("/dept/get/{id}")
    public Dept queryById(@PathVariable("id")Long id){
        return deptService.queryById(id);
    }
    @GetMapping("/dept/list")
    public List queryAll(){
        return deptService.queryAll();
    }
}

7.springcloud-provider-dept-8001 的mybatis-config.xml

这个文件可以不要，同样可以在下面的application.yml的文件里配置settiongs

8.springcloud-provider-dept-8001 的application.yml

server:
  port: 8001

#mybatis配置
mybatis:
  type-aliases-package: com.wxb.springcloud.pojo
  config-location: classpath:mybatis/mybatis-config.xml #这个就是引用上面mybatis-config.xml
  mapper-locations: classpath:mybatis/mapper/*.xml

#spring的配置
spring:
  application:
    name: springcloud-provider-dept
  datasource:
    type: com.alibaba.druid.pool.DruidDataSource
    driver-class-name: com.mysql.jdbc.Driver
    url: jdbc:mysql://localhost:3306/db01?useUnicode=true&characterEncoding=utf-8&serverTimezone=UTC&useSSL=false
    username: root #数据库用户名
    password: root #数据库密码

数据库db01，创建表

CREATE TABLE `dept` (
  `deptno` bigint(20) NOT NULL AUTO_INCREMENT,
  `dname` varchar(60) DEFAULT NULL,
  `db_source` varchar(60) DEFAULT NULL,
  PRIMARY KEY (`deptno`)
) ENGINE=InnoDB AUTO_INCREMENT=36 DEFAULT CHARSET=utf8 COMMENT='部门表'
INSERT INTO dept(dname, db_source) VALUES ('开发部',DATABASE());
INSERT INTO dept(dname, db_source) VALUES ('人事部',DATABASE());
INSERT INTO dept(dname, db_source) VALUES ('财务部',DATABASE());
INSERT INTO dept(dname, db_source) VALUES ('市场部',DATABASE());
INSERT INTO dept(dname, db_source) VALUES ('运维部',DATABASE());

9.springcloud-provider-dept-8001 的启动类

package com.wxb.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DeptProvider_8001 {
    public static void main(String args[]) {
        SpringApplication.run(DeptProvider_8001.class,args);
    }
}

保证在上面的目录下，可以扫描到其他三个目录

然后启动测试，这是本地进行测试

打开浏览器测试记得上面的controller里填的地址
http://localhost:8001/dept/add?dname=游戏部
查看数据库

http://localhost:8001/dept/get/1
浏览器返回结果

http://localhost:8001/dept/list

浏览器直接返回字符串结果

创建子工程springcloud-consurmer-dept-80

springcloud-consurmer-dept-80 的ConfigBean

package com.wxb.springcloud.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ConfigBean {
    @Bean
    public RestTemplate getRestTemplate(){
        return new RestTemplate();
    }
}

springcloud-consurmer-dept-80 的

package com.wxb.springcloud.controller;

import com.wxb.springcloud.pojo.Dept;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.client.RestTemplate;
import java.util.List;

@RestController
public class DeptConsumerController {
    //消费者，不应该有service层
    //RestTemplate  模板方法供我们调用
    //(url,实体，map，Class responseType
    @Autowired
    private RestTemplate restTemplate;

    private static final String REST_URL_RPEFIX="http://localhost:8001";

    @RequestMapping("/consumer/dept/add")
    public boolean add( Dept dept){
        System.out.println(dept.toString());
        return restTemplate.postForObject(REST_URL_RPEFIX+"/dept/add" , dept, Boolean.class);
    }

    @RequestMapping("/consumer/dept/get/{id}")
    public Dept get(@PathVariable("id")Long id){
        return restTemplate.getForObject(REST_URL_RPEFIX+"/dept/get/"+id,Dept.class);
    }
    @RequestMapping("/consumer/dept/list")
    public List queryAll(){
        return restTemplate.getForObject(REST_URL_RPEFIX+"/dept/list",List.class);
    }

}

springcloud-consurmer-dept-80 的application.yml文件

server:
  port: 80

springcloud-consurmer-dept-80 的启动类

package com.wxb.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;

@SpringBootApplication
public class DeptConsumer_80 {
    public static void main(String args[]) {
        SpringApplication.run(DeptConsumer_80.class,args);
    }
}

然后启动测试
http://localhost/consumer/dept/add?dname=风水部

返回结果为null
打开springcloud-provider-dept-8001项目的DeptController 添加参数@RequestBody 参数

重启springcloud-provider-dept-8001，测试

供远程调用实现传参，但是本地测试http://localhost:8001/dept/add?dname=风水
会出错

http://localhost/consumer/dept/get/1
返回结果

http://localhost/consumer/dept/list
返回结果

但不管怎么说已经实现供远程调用服务。前端后端分离，用这个项目可供测试
springcloud-consurmer-dept-80 供前端集成
只需修改DeptConsumerController 的REST_URL_RPEFIX 值为服务地址

springcloud-provider-dept-8001 放在服务器上启动，就可以了

springcloud 生产者消费者

Java相关栏目本月热门文章