Updated 分布式系统架构方案设计初稿.md (markdown)

+基于okHttp进行转发

+

+```java

+

+

+public class ReverseProxyServlet extends HttpServlet {

+

+ private final List<String> targets;

+ private final Random random = new Random();

+ private final OkHttpClient client = new OkHttpClient();

+

+ public ReverseProxyServlet(List<String> targets) {

+ this.targets = targets;

+ }

+

+ @Override

+ protected void service(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {

+ String target = targets.get(random.nextInt(targets.size()));

+ String targetUrl = target + req.getRequestURI();

+

+ Request proxyRequest = new Request.Builder()

+ .url(targetUrl)

+ .build();

+

+ try (Response proxyResponse = client.newCall(proxyRequest).execute()) {

+ resp.setStatus(proxyResponse.code());

+ if (proxyResponse.body() != null) {

+ resp.getOutputStream().write(proxyResponse.body().bytes());

+ }

+ }

+ }

+

+ public static void main(String[] args) throws Exception {

+ List<String> targets = new ArrayList<>();

+ targets.add("http://localhost:9091");

+ targets.add("http://localhost:9092");

+

+ Server server = new Server(9090);

+ ServletContextHandler context = new ServletContextHandler();

+ context.setContextPath("/");

+ server.setHandler(context);

+

+ context.addServlet(new ServletHolder(new ReverseProxyServlet(targets)), "/*");

+ server.start();

+ server.join();

+ }

+}

+

+```

+