个微iPad协议对接场景下Java后端的面向接口编程与依赖注入实战技巧

1. 场景背景与挑战

在对接“个微iPad协议”（即基于微信iPad版通信协议的第三方私有接口）时，后端需处理多种消息通道（如扫码登录、消息收发、好友管理等）。由于协议版本迭代快、实现方式多样（HTTP轮询、WebSocket、MQTT等），若直接硬编码具体实现，将导致系统高度耦合、难以测试和扩展。采用面向接口编程（Interface-Oriented Programming）结合Spring依赖注入（DI），可有效解耦协议细节与业务逻辑。

2. 定义统一协议接口

首先抽象出通用的消息服务接口：

package wlkankan.cn.ipadwe.protocol;

public interface WeMessageService {
    String sendMessage(String toUser, String content);
    void connect(String deviceId);
    boolean isConnected(String deviceId);
}

同时定义登录服务接口：

package wlkankan.cn.ipadwe.protocol;

public interface WeLoginService {
    String generateQrCodeUrl(String sceneId);
    LoginStatus checkLoginStatus(String sceneId);
}

其中LoginStatus为枚举：

package wlkankan.cn.ipadwe.protocol;

public enum LoginStatus {
    WAITING, SUCCESS, EXPIRED, FAILED
}

3. 多种协议实现类

针对不同协议版本或通道，提供具体实现：

package wlkankan.cn.ipadwe.protocol.impl;

import wlkankan.cn.ipadwe.protocol.WeMessageService;
import org.springframework.stereotype.Service;

@Service("ipadHttpMessageService")
public class IpadHttpMessageServiceImpl implements WeMessageService {

    @Override
    public String sendMessage(String toUser, String content) {
        // 模拟通过HTTP API发送消息
        return "sent via HTTP: " + content;
    }

    @Override
    public void connect(String deviceId) {
        // HTTP无长连接，模拟注册设备
    }

    @Override
    public boolean isConnected(String deviceId) {
        return true; // 假设始终可用
    }
}

WebSocket实现：

package wlkankan.cn.ipadwe.protocol.impl;

import wlkankan.cn.ipadwe.protocol.WeMessageService;
import org.springframework.stereotype.Service;

@Service("ipadWsMessageService")
public class IpadWsMessageServiceImpl implements WeMessageService {

    @Override
    public String sendMessage(String toUser, String content) {
        // 通过WebSocket会话发送
        return "sent via WebSocket: " + content;
    }

    @Override
    public void connect(String deviceId) {
        // 建立WebSocket连接
    }

    @Override
    public boolean isConnected(String deviceId) {
        // 查询连接状态
        return true;
    }
}

4. 依赖注入与策略选择

使用工厂模式或配置驱动选择具体实现：

package wlkankan.cn.ipadwe.config;

import wlkankan.cn.ipadwe.protocol.WeMessageService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class ProtocolConfig {

    @Autowired
    @Qualifier("ipadWsMessageService")
    private WeMessageService wsService;

    @Autowired
    @Qualifier("ipadHttpMessageService")
    private WeMessageService httpService;

    @Bean
    public WeMessageService activeMessageService() {
        // 可从配置中心读取 protocol.type = ws | http
        String protocolType = System.getProperty("protocol.type", "ws");
        return "ws".equals(protocolType) ? wsService : httpService;
    }
}

5. Controller层无感知调用

业务控制器仅依赖接口，不关心具体实现：

package wlkankan.cn.ipadwe.controller;

import wlkankan.cn.ipadwe.protocol.WeMessageService;
import wlkankan.cn.ipadwe.protocol.WeLoginService;
import org.springframework.web.bind.annotation.*;
import javax.annotation.Resource;

@RestController
@RequestMapping("/ipad-we")
public class IpadWeController {

    @Resource
    private WeMessageService messageService;

    @Resource
    private WeLoginService loginService;

    @PostMapping("/send")
    public String send(@RequestParam String to, @RequestParam String msg) {
        return messageService.sendMessage(to, msg);
    }

    @GetMapping("/qr")
    public String qr(@RequestParam String scene) {
        return loginService.generateQrCodeUrl(scene);
    }
}

6. 登录服务实现示例

package wlkankan.cn.ipadwe.protocol.impl;

import wlkankan.cn.ipadwe.protocol.WeLoginService;
import wlkankan.cn.ipadwe.protocol.LoginStatus;
import org.springframework.stereotype.Service;

@Service
public class IpadLoginServiceImpl implements WeLoginService {

    @Override
    public String generateQrCodeUrl(String sceneId) {
        return "https://qrcode.wlkankan.cn/ipad?scene=" + sceneId;
    }

    @Override
    public LoginStatus checkLoginStatus(String sceneId) {
        // 模拟：偶数sceneId视为成功
        return (sceneId.hashCode() % 2 == 0) ? LoginStatus.SUCCESS : LoginStatus.WAITING;
    }
}

7. 单元测试与Mock注入

利用Spring Test进行接口级测试：

package wlkankan.cn.ipadwe.test;

import wlkankan.cn.ipadwe.protocol.WeMessageService;
import org.junit.jupiter.api.Test;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.mock.mockito.MockBean;
import static org.mockito.Mockito.*;

@SpringBootTest
public class MessageServiceTest {

    @MockBean
    private WeMessageService messageService;

    @Test
    public void testSendMessage() {
        when(messageService.sendMessage("user123", "hello")).thenReturn("sent");
        String result = messageService.sendMessage("user123", "hello");
        verify(messageService).sendMessage("user123", "hello");
        assert "sent".equals(result);
    }
}

8. 动态切换与A/B测试支持

通过自定义注解+条件注入实现运行时切换：

@Target({ElementType.TYPE})
@Retention(RetentionPolicy.RUNTIME)
@Conditional(OnProtocolCondition.class)
public @interface ConditionalOnProtocol {
    String value();
}

配合ProtocolContextHolder存储当前请求使用的协议类型，可在网关层根据Header动态路由到不同实现。

通过面向接口编程与Spring依赖注入机制，个微iPad协议对接系统实现了高内聚、低耦合的架构，显著提升了代码可维护性、可测试性及多协议并行支持能力。