Ï正在使用Socket从以“ C”编写的服务器中获取数据。 我的Java类名称是ReceivingData,这是用于接收数据并将其存储在ArrayList中并将ArrayList传递给其他类的构造方法的代码。
package pack.exp;
import java.io.InputStream;
import java.net.Socket;
import java.util.ArrayList;
import java.util.List;
public class ReceivingData implements Runnable
{
public static void main(String[] args)
{
Thread t = new Thread(new ReceivingData());
t.start();
}
public List<String> obj1;
@Override
public void run()
{
Socket s;
InputStream stream;
try
{
s = new Socket("10.9.211.22", 6870);
stream = s.getInputStream();
byte[] data = new byte[13];
int read;
String can_Id= null;
while((read = stream.read(data)) != -1)
{
String can_Data=
String.format("%02X:%02X:%02X:%02X,
data[0], data[1], data[2], data[3]);
List<String> obj1= new ArrayList<String>();
obj1.add(can_Data.substring(0, 2));
obj1.add(can_Data.substring(3, 5));
obj1.add(can_Data.substring(6, 8));
obj1.add(can_Data.substring(9, 11));
Receiving_At_Regular_IntervalServlet rari= new
Receiving_At_Regular_IntervalServlet(obj1);
Thread.sleep(3000);
}
}
catch (Exception e)
{
e.printStackTrace();
}
}
}
这是Servlet,它从上述文件传递的ArrayList接收数据。 并将这些数据从arraylist存储到数据存储实体中,并将其部署在Google App引擎上。
package pack.exp;
@SuppressWarnings("serial")
public class Receiving_At_Regular_IntervalServlet extends HttpServlet
{
List<String> obj2= new ArrayList<String>();
public Receiving_At_Regular_IntervalServlet(List<String> obj2) throws
IOException
{
this.obj2= obj2;
System.out.println("Receiving in Web Project" + obj2);
System.out.println("");
System.out.println("");
}
public void doGet(HttpServletRequest req, HttpServletResponse resp) throws
IOException
{
Key k1 = KeyFactory.createKey("C","0D F0 0800 1");
String parameter1 = obj2.get(0);
Entity can1 = new Entity(k1);
can1.setProperty("First Parameter", parameter1);
DatastoreService datastore = DatastoreServiceFactory.getDatastoreService();
datastore.put(can1);
Entity can11 = null;
try
{
can11= datastore.get(k1);
}
catch (EntityNotFoundException e)
{
e.printStackTrace();
}
String first_P= (String) can11.getProperty("First Parameter");
resp.setContentType("text/plain");
resp.getWriter().println("Parameter--- " + first_P);
}
}
ReceivingData代码显然运行一个线程,并使用Socket从本地计算机从10.9.211.22端口6870读取数据。 没关系。 它将四个字节转换为一个列表,并将其传递给Receiving_At_Regular_IntervalServlet。 很好,但不是您需要的。
此部分可能在开发计算机上可用,但如果部署到云中则将无效。 AppEngine服务器不允许开发人员定义main(),使用Socket或与私有IP子网10通讯。忘记将代码部署到AppEngine了。
Receiving_At_Regular_IntervalServlet具有自定义构造函数。 AppEngine不会调用您的构造函数,因为其Servlet代码仅需要默认的构造函数。 那可能是您的503错误发生的时候。
使用servlet时,数据不应通过构造函数输入。 数据必须通过doGet方法的request参数的成员进入(尽管要是RESTful,您应该在此示例中使用doPut)。 您将数据插入到request参数中,但是将正确构造的http请求发送到服务器。 您的代码缺少该Web应用程序设计。
在单独的项目中构建主程序和AppEngine代码,并使用http与Servlet进行主要对话。
HTTP ERROR 503
错误
服务器抛出此错误时,您无能为力。 仅当来自服务器的服务不可用时,才抛出该错误。
您需要在客户端应用程序中对此类错误代码进行明确处理,而不是200 OK
,并且必须显示适当的消息或作为其他要求的建议。
参考 :