由于篇幅问题，《程序员》杂志08年第12期《服务器负载均衡架构之传输层负载均衡》文中的源代码没有在杂志上刊登，下面贴出其中提到的4段代码，供读者使用。
CodeSeg1.java
  1. interface IHttpResponseCache {

  3.    IHttpResponse put(String key, IHttpResponse response) throws IOException;

  5.    void remove(String key) throws IOException;

  7.    IHttpResponse get(String key) throws IOException;
  8. }



  12. class RemoteHttpResponseCache implements IHttpResponseCache {

  14.    private MemcachedClient memCachedClient;

  16.    public RemoteHttpResponseCache(InetSocketAddress... cacheServers) throws IOException {
  17.       memCachedClient = new MemcachedClient(Arrays.asList(cacheServers));
  18.    }

  20.    public IHttpResponse put(String key, IHttpResponse response) throws IOException {
  21.       byte[] bodyData = response.getBlockingBody().readBytes();

  23.       memCachedClient.set(key, 3600, bodyData);
  24.       return null;
  25.    }


  28.    public IHttpResponse get(String key) throws IOException {
  29.       byte[] bodyData = (byte[]) memCachedClient.get(key);
  30.       if (bodyData != null) {
  31.          return new HttpResponse(200, "text/plain", bodyData);
  32.       } else {
  33.          return null;
  34.       }
  35.    }


  38.    public void remove(String key) throws IOException {
  39.       memCachedClient.delete(key);
  40.    }
  41. }

CodeSeg2.java
  1. class MyRequestHandler implements IHttpRequestHandler {

  3.    public void onRequest(IHttpExchange exchange) throws IOException {

  5.       IHttpRequest request = exchange.getRequest();

  7.       int customerId = request.getRequiredIntParameter("id");
  8.       long amount = request.getRequiredLongParameter("amount");
  9.       //...


  12.       // perform some operations
  13.       //..
  14.       String response = ...

  16.       // and return the response
  17.       exchange.send(new HttpResponse(200, "text/plain", response));
  18.    }
  19. }


  22. class Server {

  24.    public static void main(String[] args) throws Exception {
  25.       HttpServer httpServer = new HttpServer(8180, new MyRequestHandler());
  26.       httpServer.run();
  27.    }
  28. }

CodeSeg3.java
  1. class CacheInterceptor implements IHttpRequestHandler {

  3.    private IHttpResponseCache cache;

  5.    public CacheInterceptor(IHttpResponseCache cache) {
  6.       this.cache = cache;
  7.    }


  10.    public void onRequest(final IHttpExchange exchange) throws IOException {

  12.       IHttpRequest request = exchange.getRequest();

  14.       // check if request is cacheable (Cache-Control header, ...)
  15.       // ...
  16.       boolean isCacheable = ...


  19.       // if request is not cacheable forward it to the next handler of the chain
  20.       if (!isCacheable) {
  21.          exchange.forward(request);
  22.          return;
  23.       }

  25.       // create the cache key
  26.       StringBuilder sb = new StringBuilder(request.getRequestURI());
  27.       TreeSet<String> sortedParamNames = new TreeSet<String>(request.getParameterNameSet());
  28.       for (String paramName : sortedParamNames) {
  29.          sb.append(URLEncoder.encode(paramName) + "=");

  31.          List<String> paramValues = Arrays.asList(request.getParameterValues(paramName));
  32.          Collections.sort(paramValues);
  33.          for (String paramValue : paramValues) {
  34.             sb.append(URLEncoder.encode(paramValue) + ", ");
  35.          }
  36.       }
  37.       final String cacheKey = URLEncoder.encode(sb.toString());

  39.       // is request in cache?
  40.       IHttpResponse cachedResponse = cache.get(cacheKey);
  41.       if (cachedResponse != null) {
  42.          IHttpResponse response = HttpUtils.copy(cachedResponse);
  43.          response.setHeader("X-Cached", "true");
  44.          exchange.send(response);

  46.       // .. no -> forward it to the next handler of the chain
  47.       } else {

  49.          // define a intermediate response handler to intercept and copy the response
  50.          IHttpResponseHandler respHdl = new IHttpResponseHandler() {

  52.             @InvokeOn(InvokeOn.MESSAGE_RECEIVED)
  53.             public void onResponse(IHttpResponse response) throws IOException {
  54.                cache.put(cacheKey, HttpUtils.copy(response));
  55.                exchange.send(response);  // forward the response to the client
  56.             }

  58.             public void onException(IOException ioe) throws IOException {
  59.                exchange.sendError(ioe);  // forward the error to the client
  60.             }
  61.          };
  62.          // forward the request to the next handler of the chain
  63.          exchange.forward(request, respHdl);
  64.       }
  65.    }
  66. }

  68. class Server {

  70.    public static void main(String[] args) throws Exception {
  71.       RequestHandlerChain handlerChain = new RequestHandlerChain();
  72.       handlerChain.addLast(new CacheInterceptor(new RemoteHttpResponseCache(new InetSocketAddress(cachSrv1, 11211), new InetSocketAddress(cachSrv2, 11211))));
  73.       handlerChain.addLast(new MyRequestHandler());

  75.       HttpServer httpServer = new HttpServer(8180, handlerChain);
  76.       httpServer.run();
  77.    }
  78. }

CodeSeg4.java
  1. class LocalHttpResponseCache extends LinkedHashMap<String, IHttpResponse> implements IHttpResponseCache {

  3.    public synchronized IHttpResponse put(String key, IHttpResponse value) {
  4.       return super.put(key, value);
  5.    }

  7.    public void remove(String key) {
  8.       super.remove(key);
  9.    }

  11.    public synchronized IHttpResponse get(String key) {
  12.       return super.get(key);
  13.    }

  15.    protected boolean removeEldestEntry(Entry<String, IHttpResponse> eldest) {
  16.       return size() > 1000;   // cache up to 1000 entries
  17.    }
  18. }

  20. class Server {

  22.    public static void main(String[] args) throws Exception {
  23.       RequestHandlerChain handlerChain = new RequestHandlerChain();
  24.       handlerChain.addLast(new CacheInterceptor(new LocalHttpResponseCache()));
  25.       handlerChain.addLast(new MyRequestHandler());

  27.       HttpServer httpServer = new HttpServer(8080, handlerChain);
  28.       httpServer.run();
  29.    }
  30. }


# 负载均衡 # 服务器
Logo
AtomGit 开源协作平台测评赛

瓜分20万奖金 获得内推名额 丰厚实物奖励 易参与易上手

更多推荐

【自然语言处理】【实体匹配】CollaborER：使用多特征协作的自监督实体匹配框架

论文地址：https://arxiv.org/pdf/2108.08090.pdf​实体匹配的目标是确定两个元组是否指向相同的现实实体。其是异常检测的前提，因为比较两个不同数据集中两个匹配元组的属性值是一种有效的异常检测方法。现有的实体匹配方法，由于特征挖掘不足或者固有特征容易出错，都不能达到稳定的性能。在本文中呈现了CollaborER\text{CollaborER}CollaborER，通过

avatar 开放原子开发者工作坊

SlidingMenu使用（一） 导入SlidingMenu

今天分享并记录下SlidingMenu的使用。SlidingMenu是github开源的一个经典的侧滑项目工具：Android Studio先看下效果，一直坚信，好的帖子应该先把效果贴出来，这样看的才有劲！ps:效果代码完全是反照网上大神demo写的，所以大家看到类似的也不要惊慌，这里就是具体实现一把ok，先来介绍在Android Studio 中如何导入SlidingMenu项目。1.githu

avatar 开放原子开发者工作坊

Socket Select & Epoll Code

之前看过Socket，一直比较懒，没有总结一下，趁着有兴致赶紧写一下Socket在Linux中被当作文件看待，对应的sock_fd也是一个文件符被操作，因为端口需要监听多个socket_fd，所以采用select机制来进行非阻塞监听。直接上一段源码说明原理//socket select example//源代码copied from http://blog.sina.com.c...

avatar 开放原子开发者工作坊