activemqforpython
㈠ windows7怎样安装vcforpython27
从官网下载最新的安装程序,基于windows的,也可以直接网络下载
点击安装,如果其他用户不需要python的话,可以使用第二个,不过我们一般都是单用户,所以没差
选择安装路径,可按默认路径安装,也可自己新建路径,新建路径一般用英文名比较好,方便命令行访问,点击 NEXT
选择模块,这个不用选,直接NEXT
程序开始复制安装文件
复制完文件后点击finish,完成安装
我们需要将python路径加入path中。右键单击 【计算机】,选择菜单属性命令,在弹出的对话框中选择 【高级系统设置】 标签,选择 高级 标签,然后点击 环境变量 按钮。选中【系统变量】中的“path”选项,单击【编辑】按钮,将弹出如下图所示的对话框。在【变量值】文本框中的末尾添加“;C:\Python27”(这里是你的安装路径),单击【确定】按钮。
㈡ python连接activemq,stomp和pyactivemq什么区别
基于文本文档(Markdown) 设想好需要的基本需要的表、字段、类型;
使用 Rails Migration 随着功能的开发逐步专创建表属;
随着细节功能的开发、需求,逐步增加字段,删除字段,或者调整字段类型;
第一个 Release 的时候清理 Migrations 合并成一个;
随着后期的改动,逐步增加、修改、删除字段或表。
基本上我的所有项目都是这么搞的,这和项目是否复杂无关。
所以我前面为什么说思路需要转变。
㈢ vcforpython27.msi怎样安装
如图所示,右键安装程序,找不到以管理员身份运行安装此程序。
因此,进行如下操专作。找到附件--命令提示符属--右键--以管理员身份运行。
进入命令提示符窗口,直接输入Python软件的 .msi 安装包所在的绝对路径。如图所示是小编的安装包的绝对路径。输完路径后,直接运行,进行程序的安装。
以下是小编的执行效果。(由于小编已经安装好了Python,所以第二次安装会出现图1的界面)
㈣ 关于activemq的python客户端
指点就做不到了。不过5年前用过,挺稳定的,速度也好。 它有现成的API,你只需要将样例拿过来改一改就可以用了。
中间件这概念似乎是很古老的东西了,你能用中间件,说明你基础很好,这个应该不是问题。
㈤ python连接activemq,stomp和pyactivemq什么区别
你好。
pyactivemq可以用stomp和openwire两种协议。
如果还有问题,可以继续追问,感谢。
㈥ vtk for python该怎样用
直接下载安装vtkpython-7.1.1-Windows-64bit.exe就可以了
才60M不到
不用像C++一样还要编译VTK,python大法好
具体步骤如下:
1)安装Python,(此处省略)
2)安装VTK,从网站http://www.vtk.org/VTK/resources/software.html下载最新版本,此文安装的是:vtkpython-7.1.1-Windows-64bit.exe
3)配置VTK环境变量:
A:把VTK中的bin文件加入系统变量中:如:PATH:C:Program FilesVTK 6.1.0in
B:设置python路径,在系统变量中创建PYTHONPATH :如:PYTHONPATH :
D:ProgramVTK_Pythonin; D:ProgramVTK_PythoninLibsite-packages
4)测试,打开python IDEL界面,输入:import vtk
>>> import vtk
没提示错误就是对的
㈦ python连接activemq,stomp和pyactivemq什么区别
第一个 Release 的时候清理 Migrations 合并成一个,或者调整字段类型、需求,逐步增加;
随着后期的改动、删除字段或表基于文本文档(Markdown) 设想好需要的基本需要的表,这和项目是否复杂无关、类型、字段。
基本上我的所有项目都是这么搞的;
使用 Rails Migration 随着功能的开发逐步创建表。
所以我前面为什么说思路需要转变;
随着细节功能的开发,逐步增加字段,删除字段、修改
㈧ 求教,如何使用Python向activeMQ发送ByteMessage类型的消息
你好,具体代码可以参考下面的:
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProcer;
import javax.jms.ObjectMessage;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.ActiveMQPrefetchPolicy;
import org.apache.camel.component.jms.JmsMessage;
import org.apache.xbean.spring.context.;
//发送TextMessage
public class SendMessage {
private static final String url = "tcp://localhost:61616";;
private static final String QUEUE_NAME = "choice.queue";
protected String expectedBody = "<hello>world!</hello>";
public void sendMessage() throws JMSException{
Connection connection = null;
try{
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(QUEUE_NAME);
MessageProcer procer = session.createProcer(destination);
TextMessage message = session.createTextMessage(expectedBody);
message.setStringProperty("headname", "remoteB");
procer.send(message);
}catch(Exception e){
e.printStackTrace();
}finally{
connection.close();
}
}
***************************************************************************************
import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import javax.jms.BytesMessage;
import javax.jms.Connection;
import javax.jms.DeliveryMode;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.MessageProcer;
import javax.jms.Session;
import org.apache.activemq.ActiveMQConnectionFactory;
//发送BytesMessage
public class SendMessage {
private String url = "tcp://localhost:61616";
public void sendMessage() throws JMSException{
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
Connection connection = connectionFactory.createConnection();
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue("test.queue");
MessageProcer procer = session.createProcer(destination);
procer.setDeliveryMode(DeliveryMode.NON_PERSISTENT);
BytesMessage message = session.createBytesMessage();
byte[] content = getFileByte("d://test.jar");
message.writeBytes(content);
try{
procer.send(message);
System.out.println("successful send message");
}catch(Exception e){
e.printStackTrace();
e.getMessage();
}finally{
session.close();
connection.close();
}
}
private byte[] getFileByte(String filename){
byte[] buffer = null;
FileInputStream fin = null;
try {
File file = new File(filename);
fin = new FileInputStream(file);
buffer = new byte[fin.available()];
fin.read(buffer);
} catch (Exception e) {
e.printStackTrace();
} finally {
try {
fin.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return buffer;
}
发送完消息后可以访问
http://localhost:8161/admin/queues.jsp
看到相应的queue中是否有消息
适用收取TextMessage消息
import javax.jms.Connection;
import javax.jms.Destination;
import javax.jms.JMSException;
import javax.jms.Message;
import javax.jms.MessageConsumer;
import javax.jms.Session;
import javax.jms.TextMessage;
import org.apache.activemq.ActiveMQConnectionFactory;
public class ReceiveMessage {
private static final String url = "tcp://172.16.168.167:61616";
private static final String QUEUE_NAME = "szf.queue";
public void receiveMessage(){
Connection connection = null;
try{
try{
ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
connection = connectionFactory.createConnection();
}catch(Exception e){
// ActiveMQConnectionFactory connectionFactory = new ActiveMQConnectionFactory(url);
// connection = connectionFactory.createConnection();
}
connection.start();
Session session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
Destination destination = session.createQueue(QUEUE_NAME);
MessageConsumer consumer = session.createConsumer(destination);
consumeMessagesAndClose(connection,session,consumer);
}catch(Exception e){
}
}
protected void consumeMessagesAndClose(Connection connection,
Session session, MessageConsumer consumer) throws JMSException {
for (int i = 0; i < 1;) {
Message message = consumer.receive(1000);
if (message != null) {
i++;
onMessage(message);
}
}
System.out.println("Closing connection");
consumer.close();
session.close();
connection.close();
}
public void onMessage(Message message){
try{
if (message instanceof TextMessage) {
TextMessage txtMsg = (TextMessage)message;
String msg = txtMsg.getText();
System.out.println("Received: " + msg);
}
}catch(Exception e){
e.printStackTrace();
}
}
public static void main(String args[]){
ReceiveMessage rm = new ReceiveMessage();
rm.receiveMessage();
}
}