80分钟100分，83行代码决赛优秀选手如何解题？

public static String stripHtmlTag(String html) {
    if (ObjectUtils.isEmpty(html)) {
        return null;
    }

    return html.replaceAll("<.*?>", "");
}

不过, 既然改bug，那尽量保留原有逻辑为好。

第二步

下面我们开始进行业务调试，按照README提示运行。/round4. 开场就挂了，看到提醒需要启动服务才行。

找到带@SpringBootApplication注解的main方法，这是spring boot程序标准的启动入口，启动, run/debug都可，如果想要断点调试的话, 用debug。

Bug4

Step1看起来没啥错，Step2出现错误，看起来是期望动态添加一个用户reporter，失败了，错误消息是缺少CSRF请求头，如果用过spring security (无论在spring MVC还是spring Webflux)的话, 在安全配置里面可能会留下印像，就是对csrf的配置。这里看到round4客户端似乎请求中不带有csrf的token，那我们只能改服务了。

注: CSRF百度一下可以了解它的作用,目的和基本机制，spring security有原生实现，只要通过配置处理就好，csrf功能默认是开启的。

@Bean
public SecurityWebFilterChain securityFilterChain(ServerHttpSecurity http) {
    return http
            .headers().disable()
            .authorizeExchange()
            .pathMatchers("/endpoints").hasAnyRole("USER")
            .pathMatchers("/users").hasAnyRole("admin")
            .pathMatchers("/ws/test").hasAnyRole("TEST") // 该行勿改动，否则影响评分
            .pathMatchers("/ws/**").hasAnyRole("admin")
            .anyExchange().authenticated()
            .and()
            .httpBasic()
            .and()
            .formLogin().disable()
      //加入这一行
            .csrf().disable()
            .build();
}

bug5

重启服务, 再次执行./round4

第二步又挂了，但是错误内容变了，变成了401，看描述是身份凭证不对，错误日志很贴心的打出了错误凭证内容，是basic auth方式，后面有一串字符。

一看=结尾的乱码字符，会比较容易联想到base64。随便找个base64解密工具，把这串文字放进去。

解出来一看，很典型的账号:密码格式，也就是尝试用admin / admin123 作为账号密码处理失败了。回到WebSecurityConfig类检查配置

@Bean
public MapReactiveUserDetailsService userDetailsService() {
    UserDetails user = User.builder()
            .username("user")
            .password("{noop}user")
            .roles("USER")
            .build();
    UserDetails admin = User.builder()
            .username("admin")
            .password("{noop}admin")
            .roles("ADMIN")
            .build();
    return new MapReactiveUserDetailsService(user, admin);
}

public final class PasswordEncoderFactories {
    private PasswordEncoderFactories() {
    }

    public static PasswordEncoder createDelegatingPasswordEncoder() {
        String encodingId = "bcrypt";
        Map<String, PasswordEncoder> encoders = new HashMap();
        encoders.put(encodingId, new BCryptPasswordEncoder());
        encoders.put("ldap", new LdapShaPasswordEncoder());
        encoders.put("MD4", new Md4PasswordEncoder());
        encoders.put("MD5", new MessageDigestPasswordEncoder("MD5"));
        encoders.put("noop", NoOpPasswordEncoder.getInstance());
        encoders.put("pbkdf2", new Pbkdf2PasswordEncoder());
        encoders.put("scrypt", new SCryptPasswordEncoder());
        encoders.put("SHA-1", new MessageDigestPasswordEncoder("SHA-1"));
        encoders.put("SHA-256", new MessageDigestPasswordEncoder("SHA-256"));
        encoders.put("sha256", new StandardPasswordEncoder());
        encoders.put("argon2", new Argon2PasswordEncoder());
        return new DelegatingPasswordEncoder(encodingId, encoders);
    }
}

可以看到，noop对应的是一个叫NoOpPasswordEncoder的实例，也就是no operation，明文拿来什么都不干直接明文存储或比较，所以这样也方便了我们修改。

总之{noop}可以看不明白是怎么回事，但是看不明白的东西不要碰，只碰明白的，admin还是认识的改成{noop}admin123。

Bug6

Step2又换个错误继续挂....

public class WebSecurityConfig {

    @Bean
    public SecurityWebFilterChain securityFilterChain(ServerHttpSecurity http) {
        return http
                .headers().disable()
                .authorizeExchange()
                .pathMatchers("/endpoints").hasAnyRole("USER")
                .pathMatchers("/users").hasAnyRole("admin")
                .pathMatchers("/ws/test").hasAnyRole("TEST") // 该行勿改动，否则影响评分
                .pathMatchers("/ws/**").hasAnyRole("admin")
                .anyExchange().authenticated()
                .and()
                .httpBasic()
                .and()
                .formLogin().disable()
                .csrf().disable()
                .build();
    }

    @Bean
    public MapReactiveUserDetailsService userDetailsService() {
        UserDetails user = User.builder()
                .username("user")
                .password("{noop}user")
                .roles("USER")
                .build();
        UserDetails admin = User.builder()
                .username("admin")
                .password("{noop}admin123")
                .roles("ADMIN")
                .build();
        return new MapReactiveUserDetailsService(user, admin);
    }

}

从配置中看，admin账号具备一个角色叫做"ADMIN"，而上面/users接口的配置是需要权限"admin"。这个不像数据库对大小写不敏感，身份权限这么严谨的东西，一个字母都不    能差，把上面的admin全都改成大写ADMIN。

Bug7

可喜可贺! Step2 跑通了，不管它干了啥，总之是跑通了! 然后处理Step3，又是权限问题，但是我们不知道到底是什么问题，如果账号密码错误的话是401，而且reporter是Step2动态加进去的，要是密码对不上那也没办法调整。

从刚才Step2调试经验来看，403 Forbidden的原因很可能出在权限上面，但是我们也不知道reporter的权限是啥，这时候就要给/users打个断点了，看看Step2到底放进来了个啥。

找到Round4Controller，addUser方法打个断点，执行./round4

看到Step2调用接口是参数username是reporter，密码是reporter，还有一个特别的字段，叫做authorities，内容是ROLE_REPORTER，看起来很可疑，似乎是给这个用户赋予权限。

而Step3调用的接口是/ws/DevStudio、/ws/Cosy、WebSecurityConfig中匹配的规则是

.pathMatchers("/ws/**").hasAnyRole("ADMIN")

.pathMatchers("/ws/**").hasAnyRole("ADMIN","ROLE_REPORTER")

再试，这次应该成.....又挂了! 错误还是一样?

那就是说刚才添加的角色不对?

.pathMatchers("/ws/**").hasAnyRole("ADMIN", "REPORTER")

再试! 可喜可贺, 有变化了! 而且提示可以打分了，调用./round4 --submit，无视掉三个灵魂问题后，总算有分数了，但是明显问题多多。看来，只是走通了，但是结果不尽如人意。

Bug8

重新执行./round4 观察输出，可以看到满里面乱码，而且几乎没有一个正常的中文，结合前面Unit Test调试，可以猜测这可能跟字符集处理有关，也就是Utils那个类应该还是有bug。

这时候从输出也大概能看出来些这个程序的目的了, 似乎是接受round4的请求, 输出一些文本。而这些业务接口入口就是/ws/**。

开始寻找/ws/**到底是怎么映射到这些方法的，首先在WebConfig找到可疑方法。

    @Autowired
    @Qualifier("ReactiveWebSocketHandler")
    private WebSocketHandler webSocketHandler;

    @Bean
    public Map<String, WebSocketHandler> webSocketUrlMap() {
        return Utils.randomWords(3)
                .stream()
                .map(w -> "/ws/" + w)
                .collect(Collectors.toMap(Function.identity(), w -> webSocketHandler));
    }

似乎注册了一个Map类型的Bean，key是/ws开头的地址，value是WebSocketHandler，而 WebSocketHandler 的定义中，声明了在 spring 容器中，它的名字是ReactiveWebSocketHandler。接着全文寻ReactiveWebSocketHandler 文本，发现另一个可疑的类。

@Component("ReactiveWebSocketHandler")
public class ReactiveWebSocketHandler implements WebSocketHandler {
    @Override
    public Mono<Void> handle(WebSocketSession session) {
        return session.send(
                session.receive()
                        .map(WebSocketMessage::getPayload)
                        .map(getBufferConverter())
                        .map(Utils::decodeMessage)
                        .map(Utils::stripHtmlTag)
                        .log()
                        .map(session::textMessage));
    }

    private Function<DataBuffer, byte[]> getBufferConverter() {
        final byte[] buffer = new byte[1024];
        return (DataBuffer dataBuffer) -> {
            int length = dataBuffer.readableByteCount();
            dataBuffer.read(buffer, 0, length);
            return buffer;
        };
    }
}

看起来很有关系，handle方法看起来是处理文本的，至于Mono是什么，baidu一下和WebFlux有关，也许不是太懂，但是看着一连串的map方法，如果java8的特性熟悉的话，很像Collections.stream()后面或者Optional类中。map的使用方法，是一连串的映射逻辑，从方法名大概猜想各自的功能：

1. WebSocketMessage::getPayload 获得请求体；
2. getBufferConverter() 转换成个buffer；
3. Utils::decodeMessage 解码；
4. Utils::stripHtmlTag 去掉tag；
5. log() 打印日志；
6. session::textMessage 向会话输出文本；

其中1，6都是spring的方法，出bug的可能性微乎其微，log一般也出不了啥错，问题可能就在2,3,4上面。

首先乱码一大片，感觉少不了decodeMessage的干系，分析源代码：

   public static String decodeMessage(byte[] rawMessage) {
        ByteArrayInputStream in = new ByteArrayInputStream(rawMessage);
        DataInputStream dis = new DataInputStream(in);

        try {
            final String charset = charsetNameDecoder.apply(dis);

            return new String(dis.readAllBytes(), charset);
        } catch (IOException e) {
            e.printStackTrace();
            return String.format("%s<_>-<_>.", e.getClass().getSimpleName()); // 此行勿动，影响评分
        }
    }

    private static final ThreadLocal<String> charsetName = new ThreadLocal<>();

    private static final CheckedFunction<DataInputStream, String> charsetNameDecoder = (DataInputStream input) -> {

        byte[] charsetNameBytes = input.readNBytes(input.readByte());

        if (charsetName.get() == null) {
            charsetName.set(new String(charsetNameBytes, ISO_8859_1));
        }

        return charsetName.get();
    };

这两个类做过Unit Test，说明硬伤不大，但是代码行数不多，慢慢分析。

decodeMessage逻辑相对清晰，看起来没大问题，那继续看charsetNameDecoder。

charsetNameDecoder很特别的是用了一个ThreadLocal来存储信息，而WebSocket是不是每次请求都用新的线程来处理也许不清楚，会不会因为线程池重用导致ThreadLocal被污染也不那么清楚，但是至少我费劲解析出了charset，仅因为threadlocal存在数据就不用我解析的了就不太对啊。

从这代码上的意思看起来像，如果能解析出charset最好，如果解析不出来的话，用之前解析出来的，所以按照这个思路调整代码：

   private static final CheckedFunction<DataInputStream, String> charsetNameDecoder = (DataInputStream input) -> {

        byte[] charsetNameBytes = input.readNBytes(input.readByte());

        if (charsetNameBytes != null && charsetNameBytes.length > 0) {
            charsetName.set(new String(charsetNameBytes, ISO_8859_1));
        }

        return charsetName.get();
    };

再试！

Bug9

可喜可贺，可以看得出来结果中的乱码明显减少，而且出现了正常的中文，说明字符集的修改有了效果，而且从输出看，似乎在尝试输出一些java代码。

再仔细观察乱码的规律，似乎都是在每一行的最后出现，乱码前面的部分看起来都还好。会不会是流太长的原因?

转向前一个步骤ReactiveWebSocketHandler::getBufferConverter

   private Function<DataBuffer, byte[]> getBufferConverter() {
        final byte[] buffer = new byte[1024];
        return (DataBuffer dataBuffer) -> {
            int length = dataBuffer.readableByteCount();
            dataBuffer.read(buffer, 0, length);
            return buffer;
        };
    }

看起来是构建一个长度为1024的数组，然后把length长度的内容填充进去... 等等？为啥知道length了还固定搞个1024？10月24号很吉利还是咋的？

改了再跑！

 private Function<DataBuffer, byte[]> getBufferConverter() {
        return (DataBuffer dataBuffer) -> {
            int length = dataBuffer.readableByteCount();
            final byte[] buffer = new byte[length];
            dataBuffer.read(buffer, 0, length);
            return buffer;
        };
    }

Bug10

乱码都消失了! 似乎都OK了! 这时候扫一眼web服务的控制台，咋输出了一堆错误?

经典错误NPE，看这一排的onNext就感觉跟那一排的map有关系，难道说传下来的数据不能有null？每个步骤检查一下，在Utils::stripHtmlTag找到可疑代码。

    if (ObjectUtils.isEmpty(html)) {
            return null;
        }

        StringBuilder builder = new StringBuilder();
        final Matcher matcher = REGULAR_HTML_TAG.matcher(html);
        while (matcher.find()) {
            matcher.appendReplacement(builder, Strings.EMPTY);
            if (log.isDebugEnabled()) {
                log.debug("remove tag {}", matcher.group("tag"));
            }
        }

        matcher.appendTail(builder);

        return builder.toString();
    }

如果传入html是空的，返回一个null，何必呢，把null改成 ""再试。

终于没有乱码和错误了，提交评分! 90分!

继续找bug! 找了有10分钟也没看出哪里错来，然后无奈再看了下README，发现最后10分是那3个问题的分数...

不看文档害死人啊...

至于最后三个问题，我是慢慢试出来的，正确答案请看主办方的解读吧...

最后

在实际工作当中，是很忌讳在没有阅读代码搞清功能的前提下debug的，因为平时没有round4给我们打分，很容易改掉一个bug，又带来一群新的。

所以，以上的攻略是基于比赛环境，在有明确的评分系统存在时追求速度的一种做法思路，并不推荐使用在日常工作中，当然debug中寻找错误的思路是共通的。

如果有充足的时间了解业务背景(比赛也不会给详细的prd...)和技术思路的前提下，这些程度的bug应该大部分都可以肉眼直接发现排除，当然日常工作中不会有这么多底层的低级bug出现，如果开发天天面对这种bug，架构师就可以拿来祭旗了...

大赛目前全部关卡开放体验，域名地址：https://code83.ide.aliyun.com/，欢迎你来。

推荐阅读

---

1、用代码玩剧本杀？第3届83行代码大赛剧情官方解析

2、无算法不Java，这道算法题很难？

---

欢迎大家使用云效，云原生时代新DevOps平台，通过云原生新技术和研发新模式，大幅提升研发效率。现云效公共云基础版不限人数0元使用。