Thrift Java 服务器 OutOfMemoryError 与 Javascript 客户端答案

【问题标题】：Thrift Java server OutOfMemoryError with Javascript clientThrift Java 服务器 OutOfMemoryError 与 Javascript 客户端
【发布时间】：2014-03-16 07:38:42
【问题描述】：

我昨天开始学习节俭。

经过一番努力，我成功执行了Java教程。 Java 服务器和客户端运行良好。

但现在，我想要一个 javascript 客户端与 Java Thrift 服务器进行通信。

为此，我移动了js/文件夹中的所有js文件。

并粘贴 index.html 代码如下：

<!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Strict//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-strict.dtd">
<html xmlns="http://www.w3.org/1999/xhtml" xml:lang="en" lang="en">
<head>
  <meta http-equiv="Content-Type" content="text/html; charset=utf-8" />
  <title>Thrift Javascript Bindings - Tutorial Example</title>

  <script src="js/thrift.js"  type="text/javascript"></script>
  <script src="js/tutorial_types.js"    type="text/javascript"></script>
  <script src="js/shared_types.js"      type="text/javascript"></script>
  <script src="js/SharedService.js"     type="text/javascript"></script>
  <script src="js/Calculator.js"        type="text/javascript"></script>

  <script type="text/javascript" src="http://ajax.googleapis.com/ajax/libs/jquery/1.4.2/jquery.min.js"></script>


  <script type="text/javascript" charset="utf-8">
  //<![CDATA[
  $(document).ready(function(){
    // remove pseudo child required for valid xhtml strict
    $("#op").children().remove();
    // add operations to it's dropdown menu
    $.each(Operation, function(key, value) {
      $('#op').append($("<option></option>").attr("value",value).text(key)); 
    });

     $('table.calculator').attr('width', 500);
  });

  function calc() {
    var transport = new Thrift.Transport("http://localhost:9090");
    var protocol  = new Thrift.Protocol(transport);
    var client    = new CalculatorClient(protocol);

    var work = new Work()
    work.num1 = $("#num1").val();
    work.num2 = $("#num2").val();
    work.op = $("#op").val();

    try {
      result = client.calculate(1, work);
      $('#result').val(result);
      $('#result').css('color', 'black');
    } catch(ouch){
      $('#result').val(ouch.why);
      $('#result').css('color', 'red');
    }
  }

  function auto_calc() {
    if ($('#autoupdate:checked').val() !== undefined) {
      calc();
    }
  }
  //]]>
  </script>

</head>
<body>
  <h2>Thrift Javascript Bindings</h2>
  <form action="">
  <table class="calculator">
    <tr>
      <td>num1</td>
      <td><input type="text" id="num1" value="20" onkeyup="javascript:auto_calc();"/></td>
    </tr>
    <tr>
      <td>Operation</td>
      <td><select id="op" size="1" onchange="javascript:auto_calc();"><option></option></select></td>
    </tr>
    <tr>
      <td>num2</td>
      <td><input type="text" id="num2" value="5" onkeyup="javascript:auto_calc();"/></td></tr>
    <tr>
      <td>result</td>
      <td><input type="text" id="result" value=""/></td></tr>
    <tr>
      <td><input type="checkbox" id="autoupdate" checked="checked"/>autoupdate</td>
      <td><input type="button" id="calculate" value="calculate" onclick="javascript:calc();"/></td>
    </tr>
  </table>
  </form>

  <p>This Java Script example uses <a href="https://git-wip-us.apache.org/repos/asf?p=thrift.git;a=blob;f=tutorial/tutorial.thrift;hb=HEAD">tutorial.thrift</a> and a Thrift server using JSON protocol and HTTP transport.
  </p>
    <p>
        <a href="http://validator.w3.org/check/referer"><img
            src="http://www.w3.org/Icons/valid-xhtml10"
            alt="Valid XHTML 1.0!" height="31" width="88" /></a>
    </p>
</body>
</html>

我换行了

var transport = new Thrift.Transport("/thrift/service/tutorial/");

与

var transport = new Thrift.Transport("http://localhost:9090");

因为，我的服务器在端口 9090 上。/thrift/service/tutorial 对我来说没有任何意义，也没有工作。

然后，当我打开我的页面时。

Java thrift 服务器崩溃并出现以下错误：

Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
    at org.apache.thrift.protocol.TBinaryProtocol.readStringBody(TBinaryProtocol.java:339)
    at org.apache.thrift.protocol.TBinaryProtocol.readMessageBegin(TBinaryProtocol.java:202)
    at org.apache.thrift.TBaseProcessor.process(TBaseProcessor.java:27)
    at org.apache.thrift.server.TSimpleServer.serve(TSimpleServer.java:83)
    at thrift.server.CalculatorServer.main(CalculatorServer.java:23)

这里是CalculatorServer java 类。

package thrift.server;

import org.apache.thrift.server.TServer;
import org.apache.thrift.server.TServer.Args;
import org.apache.thrift.server.TSimpleServer;
import org.apache.thrift.transport.TServerSocket;
import org.apache.thrift.transport.TServerTransport;
import org.apache.thrift.transport.TTransportException;

import tutorial.Calculator;

public class CalculatorServer {

    public static void main(String[] args) {
        CalculatorHandler handler = new CalculatorHandler();
        Calculator.Processor<CalculatorHandler> processor = new Calculator.Processor<>(handler);        

        try {
            TServerTransport serverTransport = new TServerSocket(9090);
            TServer server = new TSimpleServer(new Args(serverTransport).processor(processor));

            System.out.println("Starting the simple server...");
            server.serve();
        } catch (TTransportException e) {
            e.printStackTrace();
        }
    }

}

其余代码均来自 Thrift 教程。事实上，Java Thrift 服务器与 Java Thrift 客户端完美配合。我认为 Java Server 端没有任何问题。

谁能告诉我出了什么问题？

Javascript 客户端有什么替代方案吗？

我正在使用 thrift 在我的 Java SE 应用程序和本地计算机上的网站之间进行通信。因此，我可以使用 HTML+CSS+JS 开发我的 GUI，而不是使用 Java Swing。

【问题讨论】：

可以看看java代码吗？
你应该运行更多内存的服务器-Xmx1024m，然后再试一次
@RC 不，同样的错误。

标签： java javascript thrift

【解决方案1】：

默认的“TTransport”不是基于 http 协议的服务器。如果您想使用 http 作为客户端上似乎是 js 的唯一方式的通信协议，您应该使用基于 http 的“TTransport”。看看 'org.apache.thrift.server.TServlet'，这是在 servlet 中构建基于 http 的 thrift 服务器的简单方法。

您还应该在服务器端使用“TJSONProtocol”而不是“TBinaryProtocol”，因为 thrift js 不能很好地处理二进制数据。这是我之前使用的代码sn-p。

public class CalculatorServlet extends TServlet 
{
   public CalculatorServlet() 
   {
      //'Calculator' is the generated class from thrift, 
      //'CalculatorHandler' is the implement class for thrift rpc
      super(new Calculator.Processor(
            new CalculatorHandler()),
            new TJSONProtocol.Factory());
  }
}

【讨论】：

好吧，你的意思是说，我必须创建一个 Servlet 才能与 JS 客户端通信？
您的代码 sn-p 很好，但请详细说明并参考我的示例。所以，我很容易理解。
您可以创建一个 http 服务器而不是 'TServerSocket'。但这要复杂得多。 thrift java 库中只有“TServlet”可以帮助您做到这一点。
但是，在创建了 servlet 实例之后，如何将它附加到服务器上呢？因此，它可以处理传入的请求。
您应该在您的案例中为您的 servlet 嵌入一个码头（servlet 容器）。有教程wiki.eclipse.org/Jetty/Tutorial/Embedding_Jetty

【解决方案2】：

IIRC，JavaScript 仅支持 JSON 协议。这（当然）与二进制不兼容。

因此解决方案是：在您的服务器中使用 JSON 协议而不是二进制协议。

Thrift 的一个好的经验法则是，始终在两端使用相同的传输/协议堆栈。在这种特殊情况下，这意味着：

HTTP 服务器
JSON 协议
没有额外功能，例如 framed 协议（缓冲会起作用，顺便说一句）

（有一些例外，因为某些服务器类型本质上需要框架，但这是另一回事，与您的问题无关）

【讨论】：

我已经成功将Java Server协议设置为TJSONProtocol，但是传输部分如何解决？
有两个类，TExtensibleServlet extends HttpServlet，这似乎是要走的路。这里还有一些文档people.apache.org/~thejas/thrift-0.9/javadoc/org/apache/thrift/…我自己没用过。

【解决方案3】：

我一直在寻找一种在聚合物 javascript 中使用 thrift 的简单方法。最后这是我花了三天时间分析其他解决方案之后的解决方案。他们在哪里工作，但他们都需要从我的http://localhost:8088/view.html 请求中读取 view.html 本地位置文件。我发现这太贵了，因为我同时使用谷歌应用引擎和计算引擎。我无法在应用引擎上找到本地目录，所以这就是所做的。

写你的java服务器差不多like this。

这样写你的聚合物元素

<dom-module id="thrift-client">
<template>
</template>
<script>
    Polymer({
        is:'thrift-client',
        ready:function(){
            var transport = new Thrift.TXHRTransport("http://localhost:8088/service");

            var protocol  = new Thrift.TJSONProtocol(transport);

            var client = new NtvApiClient(protocol);

            var result = client.ping(); // ping the java server. custom

            console.log(result);
        }

        });
</script>

注意http://localhost可以改成http://Your_server_ip_address。
请确保 java 服务器有一个准确命名为 service
好极了，我们现在拥有从 javascript Web 客户端访问 java 服务器所需的一切，而无需提供任何文件路径。

注意，有了这个你可以很容易地在纯 js 中使用。像这样

                var transport = new Thrift.TXHRTransport("http://localhost:8088/service");
                var protocol  = new Thrift.TJSONProtocol(transport);
                var client = new NtvApiClient(protocol);
                var result = client.ping();

干杯。

【讨论】：