- linux中启动zookeeper
- dubbo-api
public interface DubboDemoService {
List<Brand> findAll();
}
- dubbo-provider
- pom.xml
<dependencies>
<dependency>
<groupId>com.chuai</groupId>
<artifactId>dubbo-api</artifactId>
<version>1.0</version>
</dependency>
<!-- Spring Boot Dubbo 依赖 -->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-framework-bom</artifactId>
<version>4.3.16.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.5</version>
<exclusions>
<exclusion>
<groupId>org.apache.thrift</groupId>
<artifactId>libthrift</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.alibaba.spring</groupId>
<artifactId>spring-context-support</artifactId>
<version>1.0.2</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo-rpc-rest</artifactId>
<version>2.6.5</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
- DubboDemoServiceImpl.java 提供者
import com.alibaba.dubbo.config.annotation.Service;
import com.chuai.api.DubboDemoService;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.List;
//注意：Service不是spring的，是阿里的dubbo的Service
@Service
public class DubboDemoServiceImpl implements DubboDemoService{
@Autowired
DubboDemoDao dubboDemoDao;
public List<Brand> findAll() {
return dubboDemoDao.findAll();
}
}
- 启动类
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
@SpringBootApplication
@EnableDubbo
public class ServiceApplication {
public static void main(String[] args) {
SpringApplication.run(ServiceApplication .class, args);
}
}
- application.yml
dubbo:
application:
name: dubbo-provider
registry:
address: zookeeper://192.168.67.130:2181
protocol:
name: dubbo
port: 20880
server:
port: 9001
- dubbo-consumer
- pom.xml
<dependencies>
<dependency>
<groupId>com.chuai</groupId>
<artifactId>dubbo-api</artifactId>
<version>1.0</version>
</dependency>
<!-- Spring Boot Dubbo 依赖 -->
<dependency>
<groupId>io.dubbo.springboot</groupId>
<artifactId>spring-boot-starter-dubbo</artifactId>
<version>1.0.0</version>
</dependency>
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-framework-bom</artifactId>
<version>4.3.16.RELEASE</version>
<type>pom</type>
<scope>import</scope>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo</artifactId>
<version>2.6.5</version>
<exclusions>
<exclusion>
<groupId>org.apache.thrift</groupId>
<artifactId>libthrift</artifactId>
</exclusion>
</exclusions>
</dependency>
<dependency>
<groupId>com.alibaba.spring</groupId>
<artifactId>spring-context-support</artifactId>
<version>1.0.2</version>
</dependency>
<dependency>
<groupId>com.alibaba</groupId>
<artifactId>dubbo-rpc-rest</artifactId>
<version>2.6.5</version>
</dependency>
<dependency>
<groupId>org.apache.curator</groupId>
<artifactId>curator-framework</artifactId>
<version>2.12.0</version>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>
- DubboDemoController.java 消费者
import com.alibaba.dubbo.config.annotation.Reference;
import com.chuai.api.DubboDemoService;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
@RestController
public class DubboDemoController{
@Reference
DubboDemoService service;
@GetMapping("/all")
public JsonResult findAll(){
return JsonResult.ok(service.findAll());
}
}
- 启动类
import com.alibaba.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
* import org.springframework.boot.autoconfigure.domain.EntityScan;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
*/
@SpringBootApplication
@EnableDubbo
public class ManagerWebApplication {
public static void main(String[] args) {
SpringApplication.run(ManagerWebApplication.class, args);
}
}
- application.yml
dubbo:
application:
name: dubbo-consumer
registry:
address: zookeeper://192.168.67.130:2181
protocol:
name: dubbo
port: 20880
server:
port: 9101
注意事项：
1、 提供者和消费者的启动类包名要相同。
2、application.yml文件除了name:不同，其他的dubbo项要相同。
3、启动类添加@EnableDubbo
4、@Reference、@Service注解要使用阿里dubbo的包
5、提供者、消费者的pom.xml都要依赖api的工程
6、可在provider的application.yml更改dubbo序列化方式为kryo
dubbo:
protocol:
serialization: kryo
