网站备案审核通过后,wordpress wp,漳州专业网站建设费用,游戏网站开发推广计划书近期公司对IP定位这块提了需要ip定位的需求#xff0c;找了半天资料#xff0c;发现了这个超级好用的python库#xff0c;基于纯真网络dat数据#xff0c;ip地址库和查询全都已经封装好了。
首先看下Github地址#xff1a;https://github.com/animalize/qqwry-python3
官…近期公司对IP定位这块提了需要ip定位的需求找了半天资料发现了这个超级好用的python库基于纯真网络dat数据ip地址库和查询全都已经封装好了。
首先看下Github地址https://github.com/animalize/qqwry-python3
官方库介绍https://pypi.org/project/qqwry-py3/
说明
项目基于python3环境项目使用qqwry库和flask轻量级接口框架。qqwry_update.py 地址库更新工具类from qqwry import updateQQwry
需要安装库pip install qqwry-py3
更新IP
#更新ip
from qqwry import updateQQwry
ret updateQQwry(11.dat)
print(ret)updateQQwry里面的参数是保存的文件名
查询IP
#查询Ip
q QQwry()
q.load_file(anti.dat)
info q.lookup(8.8.8.8)
res {city: info[0], isp: info[1]}
result json.dumps(res,ensure_asciiFalse)
print(result)
print(最后更新时间:{}.format(q.get_lastone()))Flask接口编写
#flask接口
server flask.Flask(__name__)
wry QQwry()
wry.load_file(anti.dat)server.route(/ip, methods[get])
def location():ip request.args.get(ip)print()print(ip)info wry.lookup(ip)res {ip: ip, city: info[0], isp: info[1]}print(res)return json.dumps(res, ensure_asciiFalse)
server.run(port8081, debugTrue)请求示例
http://127.0.0.1:8081/ip?ip8.8.8.8
Tomcat接口
直接调用python代码但是在调用过程中存在一个问题tomcat web页面会出现中文乱码问题这个也是通过搜索解决了。 通过在python中设置编码
import sys
import io
sys.stdout io.TextIOWrapper(sys.stdout.buffer, encodingutf-8)import java.io.IOException;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.InputStreamReader;public class MyServlet03 extends HttpServlet {String result;protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {//Process proc3;String md5List request.getParameter(ip);try {String[] args2 new String[] { python, /usr/local/phx/anti/query_ip.py,md5List};Process proc2 Runtime.getRuntime().exec(args2);BufferedReader in new BufferedReader(new InputStreamReader(proc2.getInputStream()));String line;while ((line in.readLine()) ! null) {result line;}in.close();proc2.waitFor();} catch (IOException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}response.setContentType(text/html;charsetutf-8);response.getWriter().write(result);}protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {doGet(request, response);}
}后记
关于java调用python方法的方法下面做一个总结。
1.使用Runtime.getRuntime()执行脚本文件 该方法可以运行含有python第三方库的程序 先建立python脚本文件 demo.py
import numpy as np
a np.arange(12).reshape(3,4)
print(a)java调用python程序并输出该结果
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;public class Demo {public static void main(String[] args) {// TODO Auto-generated method stubProcess proc;try {proc Runtime.getRuntime().exec(python D:\\demo.py);// 执行py文件//用输入输出流来截取结果BufferedReader in new BufferedReader(new InputStreamReader(proc.getInputStream()));String line null;while ((line in.readLine()) ! null) {System.out.println(line);}in.close();proc.waitFor();} catch (IOException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();} }
}如若向python程序中函数传递参数并执行出结果下面就举一例来说明一下。 同样建立python脚本文件demo2.py
import sysdef func(a,b):return (ab)if __name__ __main__:a []for i in range(1, len(sys.argv)):a.append((int(sys.argv[i])))print(func(a[0],a[1]))其中sys.argv用于获取参数url1url2等。而sys.argv[0]代表python程序名所以列表从1开始读取参数。 以上代码实现一个两个数做加法的程序下面看看在java中怎么传递函数参数代码如下
int a 18;
int b 23;
try {String[] args new String[] { python, D:\\demo2.py, String.valueOf(a), String.valueOf(b) };Process proc Runtime.getRuntime().exec(args);// 执行py文件BufferedReader in new BufferedReader(new InputStreamReader(proc.getInputStream()));String line null;while ((line in.readLine()) ! null) {System.out.println(line);}in.close();proc.waitFor();
} catch (IOException e) {e.printStackTrace();
} catch (InterruptedException e) {e.printStackTrace();
}其中args是String[] { “python”,path,url1,url2 }; path是python程序所在的路径url1是参数1url2是参数2以此类推。
2. 将python脚本写成进程为java提供服务
在java应用程序中调用python进程提供的服务。这种方法我认为是最好的强推python语言写得程序毕竟还是在python环境中执行最有效率。而且python应用和java应用可以运行在不同的服务器上通过进程的远程访问调用。更赞的是python运行环境还可以是虚拟环境运行tensorflow模型神马的完全没问题
python脚本文件如下
import socket
import sys
import threading
import numpy as np
from PIL import Imagedef main():# 创建服务器套接字serversocket socket.socket(socket.AF_INET,socket.SOCK_STREAM)# 获取本地主机名称host socket.gethostname()# 设置一个端口port 12345# 将套接字与本地主机和端口绑定serversocket.bind((host,port))# 设置监听最大连接数serversocket.listen(5)# 获取本地服务器的连接信息myaddr serversocket.getsockname()print(服务器地址:%s%str(myaddr))# 循环等待接受客户端信息while True:# 获取一个客户端连接clientsocket,addr serversocket.accept()print(连接地址:%s % str(addr))try:t ServerThreading(clientsocket)#为每一个请求开启一个处理线程t.start()passexcept Exception as identifier:print(identifier)passpassserversocket.close()passclass ServerThreading(threading.Thread):# words text2vec.load_lexicon()def __init__(self,clientsocket,recvsize1024*1024,encodingutf-8):threading.Thread.__init__(self)self._socket clientsocketself._recvsize recvsizeself._encoding encodingpassdef run(self):print(开启线程.....)try:#接受数据msg while True:# 读取recvsize个字节rec self._socket.recv(self._recvsize)# 解码msg rec.decode(self._encoding)# 文本接受是否完毕因为python socket不能自己判断接收数据是否完毕# 所以需要自定义协议标志数据接受完毕if msg.strip().endswith(over):msgmsg[:-4]breaksendmsg Image.open(msg)# 发送数据self._socket.send((%s%sendmsg).encode(self._encoding))passexcept Exception as identifier:self._socket.send(500.encode(self._encoding))print(identifier)passfinally:self._socket.close() print(任务结束.....)passdef __del__(self):passif __name__ __main__:main()在java代码中访问python进程的代码
package hello;
import java.lang.System;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.InetAddress;
import java.net.Socket;
import java.io.OutputStream;
import java.io.PrintStream;
import java.io.InputStream;public class hello {public static void main(String[] args){//System.out.println(Hello World!);// TODO Auto-generated method stubtry {InetAddress addr InetAddress.getLocalHost();String hostaddr.getHostName();//String ipaddr.getHostAddress().toString(); //获取本机ip//log.info(调用远程接口:hostip,port12345);// 初始化套接字设置访问服务的主机和进程端口号HOST是访问python进程的主机名称可以是IP地址或者域名PORT是python进程绑定的端口号Socket socket new Socket(host,12345);// 获取输出流对象OutputStream os socket.getOutputStream();PrintStream out new PrintStream(os);// 发送内容out.print( F:\\xxx\\0000.jpg);// 告诉服务进程内容发送完毕可以开始处理out.print(over);// 获取服务进程的输入流InputStream is socket.getInputStream();BufferedReader br new BufferedReader(new InputStreamReader(is,utf-8));String tmp null;StringBuilder sb new StringBuilder();// 读取内容while((tmpbr.readLine())!null)sb.append(tmp).append(\n);System.out.print(sb);// 解析结果//JSONArray res JSON.parseArray(sb.toString());} catch (IOException e) {e.printStackTrace();}finally {try {if(socket!null) socket.close();} catch (IOException e) {}System.out.print(远程接口调用结束.);}}
}Idea导入Eclipse的Web项目并部署到Tomcat
⒈启动Idea选择导入项目 选择导入的项目路径后选择项目类型后一路next即可。 ⒉选择File-Project Structure打开项目配置窗口ctrl alt shift s 在Modules节点下选择你的项目打开Dependencies选型卡移除错误的依赖然后将JDK和Tomcat依赖添加 ⒊在Modules节点下选择你的项目右键添加相应程序框架的配置。 ⒋在Libraries节点下新建java的类库导入classes下的jar包 ⒌在Artifact节点下直接点击Create Artifactidea会自动给你生成一个基础的artifact。 ⒍在Project节点下配置项目相关环境后点击OK ⒎配置Tomcat
参考文献
https://github.com/animalize/qqwry-python310分钟使用Python搭建自己的IP定位查询接口python3 java调用python出现中文乱码解决方案java调用python方法Idea导入Eclipse的Web项目并部署到Tomcat
