当前位置： 首页 > news >正文

Dubbo（95）如何在社交网络中应用Dubbo？

news 2025/5/5 7:21:38

在社交网络中应用Dubbo，可以通过以下步骤实现：

  1. 项目结构设计：规划项目的模块结构，通常包括服务接口模块、各个服务提供者模块（如用户服务、好友服务、消息服务等）、服务消费者模块（如前端应用、后台管理系统等）。
  2. 服务接口定义：定义各个服务的接口，确保服务提供者和消费者能够共享相同的接口。
  3. 服务提供者实现：实现各个服务接口，并配置Dubbo提供服务。
  4. 服务消费者调用：在服务消费者中引用服务接口，并通过Dubbo调用远程服务。
  5. 服务注册与发现：配置注册中心（如Zookeeper）以实现服务注册与发现。
  6. 配置管理：管理项目的配置文件，确保服务提供者和消费者能够正确连接到注册中心并发现彼此。
  7. 测试与部署：测试服务的调用，确保服务能够正常工作，并将服务部署到生产环境。

以下是一个详细的示例，展示如何在社交网络中应用Dubbo。

1. 项目结构设计

我们将创建一个包含多个模块的项目：dubbo-api、user-service、friend-service、message-service 和 frontend-application。

social-network
├── dubbo-api
│   └── src/main/java/com/example/dubbo/api
│       ├── UserService.java
│       ├── FriendService.java
│       └── MessageService.java
├── user-service
│   └── src/main/java/com/example/user
│       ├── service
│       │   └── UserServiceImpl.java
│       ├── config
│       │   └── DubboProviderConfig.java
│       └── UserServiceApplication.java
├── friend-service
│   └── src/main/java/com/example/friend
│       ├── service
│       │   └── FriendServiceImpl.java
│       ├── config
│       │   └── DubboProviderConfig.java
│       └── FriendServiceApplication.java
├── message-service
│   └── src/main/java/com/example/message
│       ├── service
│       │   └── MessageServiceImpl.java
│       ├── config
│       │   └── DubboProviderConfig.java
│       └── MessageServiceApplication.java
├── frontend-application
│   └── src/main/java/com/example/frontend
│       ├── controller
│       │   └── SocialNetworkController.java
│       ├── config
│       │   └── DubboConsumerConfig.java
│       └── FrontendApplication.java
└── pom.xml

2. 服务接口定义

2.1 创建 dubbo-api 模块

创建 dubbo-api 模块的 pom.xml 文件：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.w3.org/POM/4.0.0 http://www.w3.org/2001/04/xmldsig-more#"><modelVersion>4.0.0</modelVersion><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version><packaging>jar</packaging><dependencies><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>2.7.8</version></dependency></dependencies>
</project>
2.2 定义服务接口

在 dubbo-api/src/main/java/com/example/dubbo/api 目录下创建 UserService、FriendService 和 MessageService 接口：

package com.example.dubbo.api;public interface UserService {String getUser(String userId);
}public interface FriendService {String addFriend(String userId, String friendId);String getFriends(String userId);
}public interface MessageService {String sendMessage(String fromUserId, String toUserId, String message);String getMessages(String userId);
}

3. 服务提供者实现

3.1 创建 user-service 模块

创建 user-service 模块的 pom.xml 文件：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.w3.org/POM/4.0.0 http://www.w3.org/2001/04/xmldsig-more#"><parent><groupId>com.example</groupId><artifactId>social-network</artifactId><version>1.0-SNAPSHOT</version><relativePath>../pom.xml</relativePath></parent><artifactId>user-service</artifactId><dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter</artifactId></dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.3</version></dependency></dependencies>
</project>
3.2 实现用户服务接口

在 user-service/src/main/java/com/example/user/service 目录下创建 UserServiceImpl 类：

package com.example.user.service;import com.example.dubbo.api.UserService;
import org.apache.dubbo.config.annotation.DubboService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;@DubboService
public class UserServiceImpl implements UserService {private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class);@Overridepublic String getUser(String userId) {logger.info("Fetching user with ID: {}", userId);return "User: " + userId;}
}
3.3 配置Dubbo服务

在 user-service/src/main/java/com/example/user/config 目录下创建 DubboProviderConfig 类：

package com.example.user.config;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.Configuration;@Configuration
@EnableDubbo(scanBasePackages = "com.example.user.service")
public class DubboProviderConfig {
}
3.4 创建启动类

在 user-service/src/main/java/com/example/user 目录下创建 UserServiceApplication 类：

package com.example.user;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class UserServiceApplication {public static void main(String[] args) {SpringApplication.run(UserServiceApplication.class, args);}
}
3.5 配置文件

在 user-service/src/main/resources 目录下创建 application.yml 配置文件：

spring:application:name: user-servicemain:web-application-type: nonedubbo:application:name: user-serviceregistry:address: zookeeper://localhost:2181protocol:name: dubboport: 20880scan:base-packages: com.example.user.servicelogging:level:com.example.user: INFOfile:name: logs/user-service.log
3.6 创建 friend-service 模块

创建 friend-service 模块的 pom.xml 文件，类似于 user-service 模块。

3.7 实现好友服务接口

在 friend-service/src/main/java/com/example/friend/service 目录下创建 FriendServiceImpl 类：

package com.example.friend.service;import com.example.dubbo.api.FriendService;
import org.apache.dubbo.config.annotation.DubboService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;@DubboService
public class FriendServiceImpl implements FriendService {private static final Logger logger = LoggerFactory.getLogger(FriendServiceImpl.class);@Overridepublic String addFriend(String userId, String friendId) {logger.info("Adding friend {} for user {}", friendId, userId);return "Friend " + friendId + " added for user " + userId;}@Overridepublic String getFriends(String userId) {logger.info("Fetching friends for user {}", userId);return "Friends of user " + userId;}
}
3.8 配置Dubbo服务和启动类

在 friend-service 模块中配置Dubbo服务和启动类，类似于 user-service 模块。

3.9 创建 message-service 模块

创建 message-service 模块的 pom.xml 文件，类似于 user-service 模块。

3.10 实现消息服务接口

在 message-service/src/main/java/com/example/message/service 目录下创建 MessageServiceImpl 类：

package com.example.message.service;import com.example.dubbo.api.MessageService;
import org.apache.dubbo.config.annotation.DubboService;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;@DubboService
public class MessageServiceImpl implements MessageService {private static final Logger logger = LoggerFactory.getLogger(MessageServiceImpl.class);@Overridepublic String sendMessage(String fromUserId, String toUserId, String message) {logger.info("Sending message from {} to {}: {}", fromUserId, toUserId, message);return "Message sent from " + fromUserId + " to " + toUserId + ": " + message;}@Overridepublic String getMessages(String userId) {logger.info("Fetching messages for user {}", userId);return "Messages for user " + userId;}
}
3.11 配置Dubbo服务和启动类

在 message-service 模块中配置Dubbo服务和启动类，类似于 user-service 模块。

4. 服务消费者调用

4.1 创建 frontend-application 模块

创建 frontend-application 模块的 pom.xml 文件：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.w3.org/POM/4.0.0 http://www.w3.org/2001/04/xmldsig-more#"><parent><groupId>com.example</groupId><artifactId>social-network</artifactId><version>1.0-SNAPSHOT</version><relativePath>../pom.xml</relativePath></parent><artifactId>frontend-application</artifactId><dependencies><dependency><groupId>com.example</groupId><artifactId>dubbo-api</artifactId><version>1.0-SNAPSHOT</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-web</artifactId></dependency><dependency><groupId>ch.qos.logback</groupId><artifactId>logback-classic</artifactId><version>1.2.3</version></dependency></dependencies>
</project>
4.2 创建控制器

在 frontend-application/src/main/java/com/example/frontend/controller 目录下创建 SocialNetworkController 类：

package com.example.frontend.controller;import com.example.dubbo.api.FriendService;
import com.example.dubbo.api.MessageService;
import com.example.dubbo.api.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;@RestController
public class SocialNetworkController {private static final Logger logger = LoggerFactory.getLogger(SocialNetworkController.class);@DubboReferenceprivate UserService userService;@DubboReferenceprivate FriendService friendService;@DubboReferenceprivate MessageService messageService;@GetMapping("/getUser")public String getUser(@RequestParam String userId) {logger.info("Fetching user with ID: {}", userId);return userService.getUser(userId);}@GetMapping("/addFriend")public String addFriend(@RequestParam String userId, @RequestParam String friendId) {logger.info("Adding friend with ID: {} to user with ID: {}", friendId, userId);return friendService.addFriend(userId, friendId);}@GetMapping("/sendMessage")public String sendMessage(@RequestParam String fromUserId, @RequestParam String toUserId, @RequestParam String message) {logger.info("Sending message from {} to {}: {}", fromUserId, toUserId, message);return messageService.sendMessage(fromUserId, toUserId, message);}
}
4.3 配置Dubbo消费

在 frontend-application/src/main/java/com/example/frontend/config 目录下创建 DubboConsumerConfig 类：

package com.example.frontend.config;import org.apache.dubbo.config.spring.context.annotation.EnableDubbo;
import org.springframework.context.annotation.Configuration;@Configuration
@EnableDubbo(scanBasePackages = "com.example.frontend.controller")
public class DubboConsumerConfig {
}
4.4 创建启动类

在 frontend-application/src/main/java/com/example/frontend 目录下创建 FrontendApplication 类：

package com.example.frontend;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public class FrontendApplication {public static void main(String[] args) {SpringApplication.run(FrontendApplication.class, args);}
}
4.5 配置文件

在 frontend-application/src/main/resources 目录下创建 application.yml 配置文件：

spring:application:name: frontend-applicationdubbo:application:name: frontend-applicationregistry:address: zookeeper://localhost:2181protocol:name: dubboscan:base-packages: com.example.frontend.controllerlogging:level:com.example.frontend: INFOfile:name: logs/frontend-application.log

5. 根项目的 pom.xml

在根项目 social-network 中创建 pom.xml 文件，定义模块和依赖管理：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://www.w3.org/POM/4.0.0 http://www.w3.org/2001/04/xmldsig-more#"><modelVersion>4.0.0</modelVersion><groupId>com.example</groupId><artifactId>social-network</artifactId><version>1.0-SNAPSHOT</version><packaging>pom</packaging><modules><module>dubbo-api</module><module>user-service</module><module>friend-service</module><module>message-service</module><module>frontend-application</module></modules><dependencyManagement><dependencies><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo</artifactId><version>2.7.8</version></dependency><dependency><groupId>org.apache.dubbo</groupId><artifactId>dubbo-spring-boot-starter</artifactId><version>2.7.8</version></dependency></dependencies></dependencyManagement><build><pluginManagement><plugins><plugin><groupId>org.apache.maven.plugins</groupId><artifactId>maven-compiler-plugin</artifactId><version>3.8.1</version><configuration><source>1.8</source><target>1.8</target></configuration></plugin><plugin><groupId>org.springframework.boot</groupId><artifactId>spring-boot-maven-plugin</artifactId><version>2.3.4.RELEASE</version></plugin></plugins></pluginManagement></build>
</project>

6. 启动Zookeeper

确保Zookeeper在本地运行，默认端口为 2181。可以通过下载Zookeeper并运行以下命令启动Zookeeper：

bin/zkServer.sh start

7. 启动服务提供者和消费者

  1. 启动用户服务：运行 UserServiceApplication 类。
  2. 启动好友服务：运行 FriendServiceApplication 类。
  3. 启动消息服务：运行 MessageServiceApplication 类。
  4. 启动前端应用：运行 FrontendApplication 类。

8. 测试服务

访问前端应用的用户获取、好友添加和消息发送接口：

http://www.xdnf.cn/news/278749.html

相关文章：

  • 注意力机制
  • 2025年PMP 学习一
  • 文章记单词 | 第60篇（六级）
  • mysql中int(1) 和 int(10) 有什么区别？
  • STM32GPIO输入实战-按键key模板及移植
  • I.MX6U的GPIO配置和LED点灯实验。
  • leetcode:最小覆盖字符串
  • 【操作系统】吸烟者问题
  • NHANES指标推荐：LC9
  • Android第四次面试总结之Java基础篇（补充）
  • 【NTN 卫星通信】NTN关键问题的一些解决方法（一）
  • 55认知干货：深空产业
  • 2022年第十三届蓝桥杯省赛B组Java题解
  • 128. 最长连续序列
  • 【人工智能】大模型安全的深度剖析：DeepSeek漏洞分析与防护实践
  • 牛客周赛91 D题（数组4.0） 题解
  • 如何用更少的显存训练 PyTorch 模型
  • 【Java JUnit单元测试框架-60】深入理解JUnit：Java单元测试的艺术与实践
  • Spring AI 实战：第九章、Spring AI MCP之万站直通
  • HTML5实战指南：语义化标签与表单表格高级应用
  • AI日报 · 2025年5月04日｜Hugging Face 启动 MCP 全球创新挑战赛
  • 《工业社会的诞生》章节
  • 相向双指针-16. 最接近的三数之和
  • 基于AWS Marketplace的快速解决方案：从选型到部署实战
  • OpenFAST 开源软件介绍
  • 大学之大：高丽大学2025.5.4
  • Java并发编程-多线程基础（三）
  • 在 Ubuntu 系统中，查看已安装程序的方法
  • Redis-----认识NoSQL
  • 网络开发基础（游戏）之 心跳机制