微服务架构下的Java功能开发策略与实践

@RestController
@RequestMapping("/users")
public class UserController {

    @Autowired
    private UserService userService;

    @GetMapping("/{id}")
    public User getUserById(@PathVariable("id") Long id) {
        return userService.getUserById(id);
    }

    @PostMapping("/")
    public User createUser(@RequestBody User user) {
        return userService.createUser(user);
    }

    @DeleteMapping("/{id}")
    public void deleteUserById(@PathVariable("id") Long id) {
        userService.deleteUserById(id);
    }
}

@Component
public class MessageReceiver {

    @RabbitListener(queues = "user.created")
    public void receiveUserCreatedMessage(User user) {
        // 处理用户创建消息
    }

    @RabbitListener(queues = "user.deleted")
    public void receiveUserDeletedMessage(Long userId) {
        // 处理用户删除消息
    }
}

@Component
public class MessageSender {

    @Autowired
    private RabbitTemplate rabbitTemplate;

    public void sendUserCreatedMessage(User user) {
        rabbitTemplate.convertAndSend("user.created", user);
    }

    public void sendUserDeletedMessage(Long userId) {
        rabbitTemplate.convertAndSend("user.deleted", userId);
    }
}

version: '3'
services:
  user-service:
    build: .
    ports:
      - 8080:8080
    command: java -jar user-service.jar
    restart: always

@SpringBootApplication
public class UserServiceApplication {

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

@RestController
public class HealthController {

    @GetMapping("/health")
    public String health() {
        return "UP";
    }
}