正文
java代码连接mq java代码连接oracle数据库
提示：扫一扫查出行【扫一扫了解最新限行尾号】
复制提示
求助java连接mq及mq配置
没借用框架的话，之前自己写了一个工具类，可以参考一下
需要一个连mysql的jar包，下一个就行
package com.cn.taxi.util;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import com.mysql.jdbc.Statement;
public class DBHelper {
public static final String url = "jdbc:mysql://127.0.0.1:3306/taxi";
public static final String name = "com.mysql.jdbc.Driver";
public static final String user = "root";
public static final String password = "123";
public static Connection getConn() {
Connection conn = null;
PreparedStatement pst = null;
try {
Class.forName(name);//指定连接类型
conn = DriverManager.getConnection(url, user, password);//获取连接
} catch (Exception e) {
e.printStackTrace();
}
return conn;
}
public static void close(Connection con,Statement st,ResultSet rs) {
if(con!=null)
{
try {
con.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(st!=null)
{
try {
st.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
if(rs!=null)
{
try {
rs.close();
} catch (SQLException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
}
}
}
相关问答
Q1: java事务中调用mq,如果事务回滚,消息会被撤回吗
回。java事务中调用mq是公司开发的平台程序，程序内设置了撤回语言，如果事务回滚消息会被撤回处理，Java的事务处理，如果对数据库进行多次操作，每一次的执行或步骤都是一个事务。
Q2: 用java连接MQ时，如何获得某一个队列管
我用的方法是:
MQQueueManager qMgr = new MQQueueManager("BVMTEST");
System.out.println("queue manager is connected!");
int openOptions = MQC.MQOO_OUTPUT | MQC.MQOO_FAIL_IF_QUIESCING;
/* 打开队列 */
com.ibm.mq.MQQueue queue = qMgr.accessQueue("test1", openOptions);
然后在调用queue.getCurrentDepth()的方法的时候居然报了异常:
MQJE001: 完成代码是 2，原因为 2038
如果我不在此处调用这个方法,而在后面进行
queue.put(outMsg, new MQPutMessageOptions());方法,居然可以成功放入测试信息.
给你一个有用的代码大全：
密码：exn4
Q3: 请问用java连接MQ时,如何获得某一个队列管理器下所有队列名称。
引起这个问题一个很有可能的原因是队列管理器在不正常停止后，虽然ps -ef | grep mq看不到此队列管理器的进程，但此MQ队列管理器的进程占用的信号灯和共享内存却没有被释放掉。解决办法如下：
1. 先查看是否有此队列管理器残留的 信号灯和共享内存。命令如下：
ipcs -a | grep mq
2. 如果有，使用ipcrm命令清除 残留的信号灯和共享内存，命令如下：
ipcrm -s semphore id
ipcrm -m shared memory id
3. 再次启动MQ队列管理器
Q4: java怎样连接rocketmq
public class RocketProducer {
private DefaultMQProducer producer;
public RocketProducer() {
this.init();
}
private void init() {
if (producer == null) {
try {
producer = new DefaultMQProducer("DataRecord");
producer.setNamesrvAddr("192.168.1.11:9876");
producer.start();
} catch (Exception ex) {
LogUtil.error(ex);
this.destory();
producer = null;
}
}
}
public boolean send(String group, String queue, byte[] message) {
try {
this.init();
Message msg = new Message(group, queue, message);
SendResult result = producer.send(msg);
return (SendStatus.SEND_OK.equals(result.getSendStatus()));
} catch (Exception ex) {
LogUtil.error(ex);
}
return false;
}
public void destory() {
if (this.producer != null) {
thi
java代码连接mq的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于java代码连接oracle数据库、java代码连接mq的信息别忘了在本站进行查找喔。
