批量发送concept.send(..) about concept HOT 1 CLOSED

public void sendEntity(Entity entity) {
    //这里需要指定Class用于数据转发之后的反序列化
    ObjectMessage message = new ObjectMessage(entity, Entity.class);
    concept.send(message);
}

//注入一个编解码适配器给每个消息设置不同的数据
@Component
public class WsEntityCodecAdapter extends WebSocketMessageCodecAdapter {

    @Override
    public MessageEncoder getClientMessageEncoder(MessageEncoder encoder) {
        //自定义编码器
        return new EntityMessageEncoder(encoder);
    }

    @RequiredArgsConstructor
    public static class EntityMessageEncoder implements MessageEncoder {

        private final MessageEncoder encoder;

        @Override
        public Object encode(Message message, Connection connection, ConnectionLoadBalanceConcept concept) {
            Object payload = message.getPayload();
            //如果是实体对象
            if (payload instanceof Entity) {
                //新建一个实体对象设置内容以及编号
                Entity newEntity = new Entity();
                newEntity.setContent(((Entity) payload).getContent());
                newEntity.setId(UUID.randomUUID().toString());
                //新建一个消息对象设置消息头和新实体对象
                ObjectMessage newMessage = new ObjectMessage();
                newMessage.getHeaders().putAll(message.getHeaders());
                newMessage.setPayload(newEntity);
                //传入新消息对象
                return encoder.encode(newMessage, connection, concept);
            }
            return encoder.encode(message, connection, concept);
        }
    }
}