如何对接汽车充电桩协议，我这里给出思路，Java使用netty、php使用swoole等，可以实现自定义协议，首先监听服务端口，对充电桩的数据解析，来一条数据，解析后，处理，回复设备一条数据。这里给出JAVA版的部分示例代码：

package org.jeecg.charge.server;

import io.netty.bootstrap.ServerBootstrap;
import io.netty.channel.*;
import io.netty.channel.nio.NioEventLoopGroup;
import io.netty.channel.socket.SocketChannel;
import io.netty.channel.socket.nio.NioServerSocketChannel;
import io.netty.handler.codec.*;
import io.netty.handler.logging.LogLevel;
import io.netty.handler.logging.LoggingHandler;
import io.netty.handler.timeout.IdleStateHandler;
import lombok.extern.slf4j.Slf4j;
import org.jeecg.charge.protocol.ChargeByteToMessageDecoder;
import org.jeecg.charge.protocol.ChargeMessageToByteEncoder;
import org.jeecg.charge.server.handler.CloseHandler;
import org.jeecg.charge.server.handler.LongTimeNoReadHandler;
import org.jeecg.charge.server.strategy.ChargeOperatorFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;

import javax.annotation.PostConstruct;
import java.util.concurrent.TimeUnit;

@Slf4j
@Component
public class CarChargeServer {

    private ServerBootstrap bootstrap;

    @Autowired
    private ChargeOperatorFactory factory;

    @PostConstruct
    public void init() {
        log.info("初始化汽车充电netty服务器！");
        EventLoopGroup bossGroup = new NioEventLoopGroup(), workerGroup = new NioEventLoopGroup();

        //创建服务端启动引导类
        bootstrap = new ServerBootstrap();
        bootstrap
                .group(bossGroup, workerGroup)   //指定事件循环组
                .channel(NioServerSocketChannel.class)   //指定为NIO的ServerSocketChannel
                .childHandler(new ChannelInitializer<SocketChannel>() {
                    @Override
                    protected void initChannel(SocketChannel channel) {
                        //获取流水线，当我们需要处理客户端的数据时，实际上是像流水线一样在处理，这个流水线上可以有很多Handler
                        channel.pipeline()
                                .addLast(new LengthFieldBasedFrameDecoder(512, 1, 1, 2, 0))
                                .addLast(new LoggingHandler(LogLevel.INFO))
                                .addLast(new ChargeMessageToByteEncoder())
                                .addLast(new ChargeByteToMessageDecoder())
                                .addLast(new IdleStateHandler(20, 0, 0, TimeUnit.SECONDS))
                                .addLast(new LongTimeNoReadHandler())
                                .addLast(new ChannelInboundHandlerAdapter() {
                                    @Override
                                    public void channelRead(ChannelHandlerContext ctx, Object msg) {  //ctx是上下文，msg是收到的消息，默认以ByteBuf形式
                                        String s = msg.toString();
                                        log.info("charge equipment request msg : {}", s);
                                        String type = s.substring(10, 12);
                                        log.info("charge equipment  request type : {}", type);
                                        factory.getBaseChargeStrategy(type).execute(ctx, s);
                                    }
                                }).addLast(new CloseHandler());
                    }
                });
        //最后绑定端口，启动
        bootstrap.bind(1999);
    }

}

给出PHP版服务代码：

<?php

namespace cgcore\command;

use Channel\Server;
use GatewayWorker\BusinessWorker;
use GatewayWorker\Register;
use think\console\Command;
use think\console\Input;
use think\console\input\Argument;
use think\console\input\Option;
use think\console\Output;
use Workerman\Worker;

class Bullc extends Command
{
    /**
     * @var array
     */
    protected $config = [];

    /**
     * @var Worker
     */
    protected $registerWorkerServer;

    /**
     * @var Server
     */
    protected $gatewayWorkerServer;

    /**
     * @var Server
     */
    protected $businessWorkerServer;

    /**
     * @var Input
     */
    public $input;

    /**
     * @var Output
     */
    public $output;

    protected function configure()
    {
        // 指令配置
        $this->setName('bullc')
            ->addArgument('status', Argument::REQUIRED, 'start/stop/reload/status/connections')
            ->addOption('d', null, Option::VALUE_NONE, 'daemon（守护进程）方式启动')
            ->setDescription('start/stop/restart gatewayworker');
    }

    protected function init(Input $input, Output $output)
    {
        ini_set('default_socket_timeout', -1);
        global $argv;
        $argv[1] = $input->getArgument('status') ?: 'start';
        if ($input->hasOption('d')) {
            $argv[2] = '-d';
        } else {
            unset($argv[2]);
        }
        $gatewayworker = \think\Config::get('gatewayworker');
        $this->config = $gatewayworker['bullc'];
    }

    protected function execute(Input $input, Output $output)
    {
        $this->init($input, $output);
        $this->bindHandle();
        try {
            Worker::$pidFile = RUNTIME_PATH . 'bullc.pid';
            Worker::$logFile = RUNTIME_PATH . 'bullc.log';
            Worker::runAll();
        } catch (\Exception $e) {
            $output->warning($e->getMessage());
        }
    }

    protected function bindHandle()
    {
        if (is_null($this->registerWorkerServer)) {
            $this->registerWorkerServer = new Register('text://' . $this->config['registerAddress']);
            $this->registerWorkerServer->name = isset($this->config['name']) ? ($this->config['name'] . 'Register') : 'bullcRegister';
        }

        if (is_null($this->gatewayWorkerServer)) {
            $gateway = new \GatewayWorker\Gateway("{$this->config['protocol']}://" . config('site.bullc_server_port'));

            // gateway名称，status方便查看
            $gateway->name = isset($this->config['name']) ? ($this->config['name'] . 'Gateway') : 'bullcAppGateway';
            // gateway进程数
            $gateway->count = $this->config['serverCount'] ?? 4;
            // 本机ip，分布式部署时使用内网ip
            $gateway->lanIp = '127.0.0.1';
            // 内部通讯起始端口，假如$gateway->count=4，起始端口为4000
            // 则一般会使用4000 4001 4002 4003 4个端口作为内部通讯端口
            $gateway->startPort = $this->config['startPort'];
            // 服务注册地址
            $gateway->registerAddress = $this->config['registerAddress'];
            // 心跳间隔
            $gateway->pingInterval = 30;
            $gateway->pingNotResponseLimit = 5;
            //心跳数据
//            $gateway->pingData = '{"type":"ping"}';
            $this->gatewayWorkerServer = $gateway;
        }

        if (is_null($this->businessWorkerServer)) {
            // bussinessWorker 进程
            $worker = new BusinessWorker();
            $worker->eventHandler = $this->config['eventHandler'];
            // worker名称
            $worker->name = isset($this->config['name']) ? ($this->config['name'] . 'BusinessWorker') : 'bullcAppBusinessWorker';
            // bussinessWorker进程数量
            $worker->count = $this->config['serverCount'] ?? 4;
            // 服务注册地址
            $worker->registerAddress = $this->config['registerAddress'];
            $this->businessWorkerServer = $worker;
        }
    }
}

微信小程序搜索：河南玉阳软件科技

 充值模式： 平台充值，全平台使用，消费分账

• 系统代理(合伙)模式：

• 按电费服务费比例分成

• 目前分账为系统记录、代理商申请提现（微信自动打款或线下打款），需要空中分账的客户对接三方支付渠道