- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我目前正在从补充该服务的桌面应用程序中为我的 Web 应用程序实现一个 REST 接口(interface)。我们使用 Python 和 Flask 来实现 REST 服务器。
我们有这样一种情况,Java 客户端将请求一个 POST,而 python 服务器端将处理该 post,直到它需要连接到 MySQL 数据库。
这是 python/flask 代码:
@app.route("/update_project/<project_data>", methods=['GET','POST'])
def updateWPProject(project_data):
"""project_data = user+++++pw+++++pj_jsondoc.
This will update an existing project data or insert a non-existant project data item."""
usrpw = project_data.split("+++++")
dblogin = wplogin(usr=usrpw[0], pw=usrpw[1])
if dblogin[0] == 'SUCCESS':
db_name = dblogin[1][0].strip()
db_user = dblogin[1][1].strip()
db_pw = dblogin[1][2].strip()
if flask.request.method == 'POST':
fname = flask.request.form['fName']
if fname:
pj = Project()
try:
pj = json.loads(fname)
except TypeError:
sys.stdout.write("JSON conversion error...%s" % sys.exc_info()[0])
except AttributeError:
sys.stdout.write("JSON conversion error...%s" % sys.exc_info()[0])
updateProject(db_name,db_user,db_pw,pj)
#return redirect(url_for('/'))
else:
return 'Login failure.'
pass
在到达“updateProject(db_name,db_user,db_pw,pj)”行之前,一切正常。然后它将转到该函数,并在“cursor=conn.cursor()”处返回 500,但没有完成该函数。
def updateProject(dbname, dbuser, dbpw, pj):
"""Updates or inserts a project record is not exists. PJ passed as an argument is a Project object."""
try:
conn = getConnection(dbuser, dbpw, dbname)
cursor = conn.cursor()
except:
sys.stdout.write("MySQL connection error...%s" % sys.exc_info()[0])
sql_stmt = """INSERT INTO projects( projNo, projName, worksteplabel, workstep1label, workstep2label, workstep3label, resultlabel, result1label, result2label, result3label, projectowner, dbname, dblogin, dbpw, role, preference1, preference2, preference3 )
VALUES (
'projNo', 'projName', 'wslabel', 'wslabel', 'wslabel', 'wslabel', 'rlabel', 'rlabel', 'rlabel', 'rlabel', 'pjowner', 'dbname', 'dblogin', 'dbpw', 'role', 'pref1', 'pref2', 'pref3'
) ON DUPLICATE
KEY UPDATE projName = 'projName',
worksteplabel = 'wslabel',
workstep1label = 'wslabel',
workstep2label = 'wslabel',
workstep3label = 'wslabel',
resultlabel = 'rlabel',
result1label = 'rlabel',
result2label = 'rlabel',
result3label = 'rlabel',
projectowner = 'pjowner',
dbname = 'dbname',
dblogin = 'dblogin',
dbpw = 'dbpw',
role = 'role',
preference1 = 'pref1',
preference2 = 'pref2',
preference3 = 'pref3' )
try:
cursor.execute(sql_stmt)
return 'SUCCESS'
except MySQLdb.Error:
sys.stdout.write("MySQLdb error...%s" % sys.exc_info()[0])
return 'FAILURE'
在 Java 客户端,我使用以下代码从客户端发送 POST 请求和数据。
public void DB_NewProjectREST(ProjectData proj, WPUser usr) {
// public static String excutePost(String targetURL, String urlParameters)
//URL url;
HttpURLConnection connection = null;
///First, all the GSON/JSon stuff up front
Gson gson = new Gson();
//convert java object to JSON format
String json = gson.toJson(proj);
//Then credentials and send string
String send_string = usr.getUserEmail()+"+++++"+usr.getUserHash();
try {
//Create connection
URL url = new URL("http://127.0.0.1:5000/update_project/"+send_string);
String urlParameters = "fName=" + URLEncoder.encode(json, "UTF-8");
connection = (HttpURLConnection)url.openConnection();
connection.setRequestMethod("POST");
connection.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
connection.setRequestProperty("Content-Length", "" + Integer.toString(urlParameters.getBytes().length));
connection.setRequestProperty("Content-Language", "en-US");
connection.setUseCaches(false);
connection.setDoInput(true);
connection.setDoOutput(true);
//Send request
DataOutputStream wr = new DataOutputStream (connection.getOutputStream ());
wr.writeBytes (urlParameters);
wr.flush ();
wr.close ();
//Get Response
InputStream is = connection.getInputStream();
BufferedReader rd = new BufferedReader(new InputStreamReader(is));
String line;
StringBuffer response = new StringBuffer();
while((line = rd.readLine()) != null) {
response.append(line);
response.append('\r');
}
rd.close();
} catch (Exception e) {
e.printStackTrace();
//return null;
}finally {
if(connection != null) {
connection.disconnect();
}
}
}
似乎我必须将某种响应(针对输入流)发送回客户端,这就是我的 python 代码突然返回的地方。(?)数据从 java 客户端获取到 python/flask 代码,所以有什么方法可以快速返回“确定”并继续处理数据库更新。或者,python updateProject 函数中的游标连接调用是否以某种方式干扰了 http 连接?
感谢任何帮助。
最佳答案
这是在 python 服务器端运行的代码,但不确定它是否是“正确”的方式....
@app.route("/update_project/<project_data>", methods=['GET','POST'])
def updateWPProject(project_data):
"""project_data = user+++++pw+++++pj_jsondoc.
This will update an existing project data or insert a non-existant project data item."""
usrpw = project_data.split("+++++")
dblogin = wplogin(usr=usrpw[0], pw=usrpw[1])
if dblogin[0] == 'SUCCESS':
db_name = dblogin[1][0].strip()
db_user = dblogin[1][1].strip()
db_pw = dblogin[1][2].strip()
if flask.request.method == 'POST':
fname = flask.request.form['fName']
if fname:
pj = Project()
try:
pj = json.loads(fname)
try:
#threading.Thread(target=updateProject, args=(db_name,db_user,db_pw,pj)).start()
return Response(updateProject(db_name,db_user,db_pw,pj), direct_passthrough=True)
except Exception, errtxt:
sys.stdout.write(errtxt)
#threading.thread.start_new_thread(updateProject,(db_name,db_user,db_pw,pj))
except TypeError:
sys.stdout.write("JSON conversion error...%s" % sys.exc_info()[0])
except AttributeError:
sys.stdout.write("JSON conversion error...%s" % sys.exc_info()[0])
else:
return 'Login failure.'
pass
最值得注意的是,'return Response(......' 解决了这个挑战。我认为。
关于java - Python/Flask 服务器端 - Java/HttpURLConnection 客户端 - REST 实现,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5060294/
我在使用 Jade 和 express 时遇到了一些问题。这是 serder 端: router.get('/login', function (req, res) { res.status(2
是否可以使用 JavaScript 服务器端,从而在某些核心计算中不会显示在页面源代码中? 我正在开发一款游戏,代码的一个关键部分只需要在服务器端计算然后传回客户端。 我的整个游戏都是用 Javasc
我正在寻找有关如何使用 ExtJS 4 实现安全页面的信息。我所说的安全页面是指用户将使用 Siteminder (SSO) 登录我们的网站,因此我们将拥有用户的身份。然后我们将通过进行数据库/LDA
我的 Centos 7 服务器正在运行 apache 2.4.6,并且正在使用 mod_wsgi 提供 django webapp。我的问题是我无法从另一台计算机的浏览器访问服务器 url。我没有从
我们收到了客户的请求,要求我们基于 ExtJS 框架构建 Web 应用程序。我查看了互联网,发现 ExtJs 只是一个客户端 javascript 控件,但我认为 Web 应用程序也必须具有服务器端
我有三个组件。 组件一包含组件二和三。 组件二是一个列表。 组件三用于向数据库添加项目。 当我将一个项目保存到数据库时,我想更新组件二中的列表。 我怎么做? 最佳答案 设想 让我们假设:
欢迎, 我正在寻找能使我以尽可能高的格式下载youtube视频的youtube api。 几年前,这项工作更为简单,因为url拥有关于质量的信息,例如“fmt = 22”或“fmt = 6”,我们现在
我想将电子邮件 x@x.com 的用户密码设置为“an”。但代码不起作用。这是我的云代码: Parse.Cloud.define('testSetPasswordForUser', functio
正在阅读http://cocoawithlove.com/2010/03/streaming-mp3aac-audio-again.html这篇文章,想知道如何在服务器端实现它,是否像将文件放在htd
我有一个使用一些 css/javascript 选项卡的 php 脚本,它们在我的本地服务器上运行,但当我上传到我的在线服务器时则不起作用。 只是想知道是否有人知道为什么会出现这种情况?所有路径都
是否可以从 JavaScript 脚本获取服务器端页面的源代码?我希望能够获取服务器上同一文件夹中的页面的源代码。除了javascript之外,是否可以不使用任何其他东西? 最佳答案 如果您想从 ja
.NET 4.0 我正在寻找在我们的服务器上生成Word文档的最简单方法。 局限性: 服务器端 我不想在服务器上安装word 数据源是XML 我试图用XSLT生成快速简单的DOCX,但是我可以找到的用
我正在使用 native jQuery 验证库来验证在联系表单中输入的电子邮件地址。由于这是一个表达式引擎站点,因此我使用其电子邮件验证器作为服务器端备份。 当我输入 test@b.c 时,jQuer
我使用带有服务器端处理的数据表来显示数万行。我需要通过复选框过滤这些数据。我能够制作一个工作正常的复选框,但我不知道如何添加多个复选框以协同工作。我找到了 similar solution在这里,但我
我正在尝试编写一个消息传递应用程序,并且我能够发送消息(显示为服务器客户端正确显示消息)但随后将我的客户端踢出服务器。服务器打印以下错误: java.io.EOFException at java.i
如果设备是移动设备,如何防止侧边栏加载服务器端资源?我了解如何通过 CSS 隐藏,但我更感兴趣的是防止对服务器的调用。 最佳答案 WordPress有一个名为wp_is_mobile()的函数它将检查
我有一个返回 text/event-stream 数据的网址,因此我尝试连接并打印我找到的所有内容: var url = "..." var source = new EventSource(url)
我得到这样的错误列表:{ error: [ "Email is required", "First Name is required"] } 我需要如何修改它,以获取包含字段名称的列表? public
我正在尝试使用 ASIFormDataRequest 将数据发送到 ASP.net 服务器端。我创建了一个aspx页面。目前我可以得到这两个纯文本。但是我不知道如何通过 Request.Form 在
我在 ${host}/api/graphql 有一个可通过 POST 访问的快速 graphql 端点。 在那条路线上,我有身份验证中间件,如果用户未登录,我想重定向到登录页面。 看起来有点像这样。
我是一名优秀的程序员,十分优秀!