用 Dubbo 传输文件？被老板一顿揍！

往期热门文章：
1、45 个 Git 经典操作场景，专治不会合代码！
2、当 Transactional 碰到锁，有个大坑！
3、为了甩锅，我写了个牛逼的日志切面！
4、撸了一个高仿 B站！
5、Spring Boot 生产中 16 条最佳实践

Dubbo 怎么传文件？

void sendPhoto(File photo);

void sendPhoto(byte[] photo);

单连接模型问题

因为服务的现状大都是服务提供者少，通常只有几台机器，而服务的消费者多，可能整个网站都在访问该服务，比如 Morgan 的提供者只有 6 台提供者，却有上百台消费者，每天有 1.5 亿次调用，如果采用常规的 hessian 服务，服务提供者很容易就被压跨，通过单一连接，保证单一消费者不会压死提供者，长连接，减少连接握手验证等，并使用异步 IO，复用线程池，防止 C10K 问题。

<dubbo:service connections="1"/>
<dubbo:reference connections="1"/>

为什么 HTTP 协议“适合”传文件？

Feign 适合传输文件吗

interface SomeApi {

  // File parameter
  @RequestLine("POST /send_photo")
  @Headers("Content-Type: multipart/form-data")
  void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") File photo);

  // byte[] parameter
  @RequestLine("POST /send_photo")
  @Headers("Content-Type: multipart/form-data")
  void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") byte[] photo);

  // FormData parameter
  @RequestLine("POST /send_photo")
  @Headers("Content-Type: multipart/form-data")
  void sendPhoto (@Param("is_public") Boolean isPublic, @Param("photo") FormData photo);

  // MultipartFile parameter
  @RequestLine("POST /send_photo")
  @Headers("Content-Type: multipart/form-data")
  void sendPhoto(@RequestPart(value = "photo") MultipartFile photo);

  // Group all parameters within a POJO
  @RequestLine("POST /send_photo")
  @Headers("Content-Type: multipart/form-data")
  void sendPhoto (MyPojo pojo);

  class MyPojo {

    @FormProperty("is_public")
    Boolean isPublic;

    File photo;
  }
}

@RequiredArgsConstructor
@FieldDefaults(level = PRIVATE, makeFinal = true)
public class Output implements Closeable {

  ByteArrayOutputStream outputStream = new ByteArrayOutputStream();

  //所有的数据在“编码”之后，仍然会写入到 ByteArrayOutputStream 这个内存 OutputStream 中
  public Output write (byte[] bytes) {
    outputStream.write(bytes);
    return this;
  }

  public Output write (byte[] bytes, int offset, int length) {
    outputStream.write(bytes, offset, length);
    return this;
  }

  public byte[] toByteArray () {
    return outputStream.toByteArray();
  }

}

总结

往期热门文章：
1、我滴个乖乖，我复现了Spring的漏洞，害怕！
2、分布式锁用 Redis 还是 Zookeeper？
3、最适合晚上睡不着看的 8 个网站，建议收藏哦
4、String长度有限制吗？
5、14家互联网公司裁员（1-2月裁员清单）
6、Redis实现分布式锁的8大坑！切记！
7、请立即卸载这款 IDEA 插件！
8、Thread.sleep(0) 到底有什么用？
9、为什么不建议用try catch处理异常？
10、MySQL 为啥不能用 UUID 做主键？