SpringBoot实现微服务通信的多种方式

package cn.juwatech.controller;

import cn.juwatech.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    @Autowired
    private UserService userService;

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

package cn.juwatech.service;

import org.springframework.stereotype.Service;

@Service
public class UserService {

    public String getUserById(Long id) {
        // 调用其他微服务获取用户信息的逻辑
        return "User with id " + id;
    }
}

package cn.juwatech.controller;

import cn.juwatech.service.UserService;
import org.apache.dubbo.config.annotation.DubboReference;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;

@RestController
public class UserController {

    @DubboReference(version = "1.0.0")
    private UserService userService;

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

package cn.juwatech.service;

import org.apache.dubbo.config.annotation.DubboService;
import org.springframework.stereotype.Service;

@DubboService(version = "1.0.0")
@Service
public class UserServiceImpl implements UserService {

    @Override
    public String getUserById(Long id) {
        // 实现获取用户信息的逻辑
        return "User with id " + id;
    }
}

package cn.juwatech.listener;

import cn.juwatech.service.UserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

@Component
public class UserEventListener {

    @Autowired
    private UserService userService;

    @KafkaListener(topics = "user-events", groupId = "user-group")
    public void handleUserEvent(String userId) {
        String userInfo = userService.getUserById(Long.valueOf(userId));
        // 处理用户事件的逻辑
        System.out.println("Received user event for user: " + userInfo);
    }
}

package cn.juwatech.grpc;

import cn.juwatech.UserRequest;
import cn.juwatech.UserResponse;
import cn.juwatech.UserServiceGrpc;
import io.grpc.stub.StreamObserver;
import org.lognet.springboot.grpc.GRpcService;

@GRpcService
public class UserGrpcService extends UserServiceGrpc.UserServiceImplBase {

    @Override
    public void getUserById(UserRequest request, StreamObserver<UserResponse> responseObserver) {
        // 实现获取用户信息的逻辑
        long userId = request.getUserId();
        UserResponse response = UserResponse.newBuilder()
                .setMessage("User with id " + userId)
                .build();
        responseObserver.onNext(response);
        responseObserver.onCompleted();
    }
}