关于mqsjava的信息

今天给各位分享mqsjava的知识，其中也会对进行解释，如果能碰巧解决你现在面临的问题，别忘了关注本站，现在开始吧！

本文目录一览：

• 1、Android 百度map 报错，运行不起来问题
• 2、现在最常用的Java消息队列中间件是哪个
• 3、rocketmq 怎么实现发送顺序消息
• 4、java怎样将网页上面的数据以pdf的格式导出,求代码

Android 百度map 报错，运行不起来问题

E/NativeLoader: found libBaiduMapSDK_base_v6_0_0.so error

E/cn.pinming.zz: No implementation found for int com.baidu.mapsdkplatform.comjni.tools.JNITools.initClass(java.lang.Object, int) (tried Java_com_baidu_mapsdkplatform_comjni_tools_JNITools_initClass and Java_com_baidu_mapsdkplatform_comjni_tools_JNITools_initClass__Ljava_lang_Object_2I)

D/AndroidRuntime: Shutting down VM

E/AndroidRuntime: FATAL EXCEPTION: main

    Process: cn.pinming.zz, PID: 12485

    java.lang.UnsatisfiedLinkError: No implementation found for int com.baidu.mapsdkplatform.comjni.tools.JNITools.initClass(java.lang.Object, int) (tried Java_com_baidu_mapsdkplatform_comjni_tools_JNITools_initClass and Java_com_baidu_mapsdkplatform_comjni_tools_JNITools_initClass__Ljava_lang_Object_2I)

        at com.baidu.mapsdkplatform.comjni.tools.JNITools.initClass(Native Method)

        at com.baidu.mapsdkplatform.comjni.tools.a.b(Unknown Source:6)

        at com.baidu.mapsdkplatform.comapi.a.clinit(Unknown Source:23)

        at com.baidu.mapsdkplatform.comapi.a.a(Unknown Source:0)

        at com.baidu.mapsdkplatform.comapi.c.a(Unknown Source:17)

        at com.baidu.mapapi.SDKInitializer.initialize(Unknown Source:2)

        at com.weqia.wq.WeqiaApplication.onCreate(WeqiaApplication.java:111)

        at cn.pinming.contactmodule.ContactApplicationLogic.onCreate(ContactApplicationLogic.java:47)

        at cn.pinming.platform.PlatformApplication.onCreate(PlatformApplication.java:42)

        at android.app.Instrumentation.callApplicationOnCreate(Instrumentation.java:1155)

        at android.app.ActivityThread.handleBindApplication(ActivityThread.java:5948)

        at android.app.ActivityThread.access$1200(ActivityThread.java:200)

        at android.app.ActivityThread$H.handleMessage(ActivityThread.java:1673)

        at android.os.Handler.dispatchMessage(Handler.java:106)

        at android.os.Looper.loop(Looper.java:207)

        at android.app.ActivityThread.main(ActivityThread.java:6809)

        at java.lang.reflect.Method.invoke(Native Method)

        at com.android.internal.os.RuntimeInit$MethodAndArgsCaller.run(RuntimeInit.java:547)

        at com.android.internal.os.ZygoteInit.main(ZygoteInit.java:876)

E/MQSEventManagerDelegate: failed to get MQSService.

注释掉这段就可以了

现在最常用的Java消息队列中间件是哪个

ActiveMQ，是Apache出品，最流行的，能力强劲的开源消息总线。ActiveMQ 是一个完全支持JMS1.1和J2EE 1.4规范的 JMS Provider实现,尽管JMS规范出台已经是很久的事情了,但是JMS在当今的J2EE应用中间仍然扮演着特殊的地位。

MetaQ，是一款完全的队列模型消息中间件，服务器使用Java语言编写，可在多种软硬件平台上部署。客户端支持Java、C++编程语言。单台服务器可支持1万以上个消息队列，通过扩容服务器，队列数几乎可任意横向扩展。每个队列都是持久化、长度无限（取决于磁盘空间大小）、并且可从队列任意位置开始消费

rocketmq 怎么实现发送顺序消息

rocketmq的顺序消息需要满足2点：

1.Producer端保证发送消息有序，且发送到同一个队列。

2.consumer端保证消费同一个队列。

先看个例子，代码版本跟前面的一样。

Producer类：

import Java.io.IOException;

import java.text.SimpleDateFormat;

import java.util.Date;

import java.util.List;

import com.alibaba.rocketmq.client.exception.MQBrokerException;

import com.alibaba.rocketmq.client.exception.MQClientException;

import com.alibaba.rocketmq.client.producer.DefaultMQProducer;

import com.alibaba.rocketmq.client.producer.messageQueueSelector;

import com.alibaba.rocketmq.client.producer.SendResult;

import com.alibaba.rocketmq.common.message.Message;

import com.alibaba.rocketmq.common.message.MessageQueue;

import com.alibaba.rocketmq.remoting.exception.RemotingException;

/**

* Producer，发送顺序消息

*/

public class Producer {

public static void main(String[] args) throws IOException {

try {

DefaultMQProducer producer = new DefaultMQProducer("please_rename_unique_group_name");

producer.setNamesrvAddr("192.168.0.104:9876");

producer.start();

String[] tags = new String[] { "TagA", "TagC", "TagD" };

Date date = new Date();

SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");

String dateStr = sdf.format(date);

for (int i = 0; i 10; i++) {

// 加个时间后缀

String body = dateStr + " Hello RocketMQ " + i;

Message msg = new Message("TopicTestjjj", tags[i % tags.length], "KEY" + i, body.getBytes());

SendResult sendResult = producer.send(msg, new MessageQueueSelector() {

@Override

public MessageQueue select(ListMessageQueue mqs, Message msg, Object arg) {

Integer id = (Integer) arg;

return mqs.get(id);

}

}, 0);//0是队列的下标

system.out.println(sendResult + ", body:" + body);

}

producer.shutdown();

} catch (MQClientException e) {

e.printStackTrace();

} catch (RemotingException e) {

e.printStackTrace();

} catch (MQBrokerException e) {

e.printStackTrace();

} catch (InterruptedException e) {

e.printStackTrace();

}

System.in.read();

}

}

Consumer端：

import java.util.List;

import java.util.Random;

import java.util.concurrent.TimeUnit;

import com.alibaba.rocketmq.client.consumer.DefaultMQPushConsumer;

import com.alibaba.rocketmq.client.consumer.listener.ConsumeOrderlyContext;

import com.alibaba.rocketmq.client.consumer.listener.ConsumeOrderlyStatus;

import com.alibaba.rocketmq.client.consumer.listener.MessageListenerOrderly;

import com.alibaba.rocketmq.client.exception.MQClientException;

import com.alibaba.rocketmq.common.consumer.ConsumeFromWhere;

import com.alibaba.rocketmq.common.message.MessageExt;

/**

* 顺序消息消费，带事务方式（应用可控制Offset什么时候提交）

*/

public class Consumer {

public static void main(String[] args) throws MQClientException {

DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("please_rename_unique_group_name_3");

consumer.setNamesrvAddr("192.168.0.104:9876");

/**

* 设置Consumer第一次启动是从队列头部开始消费还是队列尾部开始消费br

* 如果非第一次启动，那么按照上次消费的位置继续消费

*/

consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET);

consumer.subscribe("TopicTestjjj", "TagA || TagC || TagD");

consumer.registerMessageListener(new MessageListenerOrderly() {

Random random = new Random();

@Override

public ConsumeOrderlyStatus consumeMessage(ListMessageExt msgs, ConsumeOrderlyContext context) {

context.setAutoCommit(true);

System.out.print(Thread.currentThread().getName() + " Receive New Messages: " );

for (MessageExt msg: msgs) {

System.out.println(msg + ", content:" + new String(msg.getBody()));

}

try {

//模拟业务逻辑处理中...

TimeUnit.SECONDS.sleep(random.nextInt(10));

} catch (Exception e) {

e.printStackTrace();

}

return ConsumeOrderlyStatus.SUCCESS;

}

});

consumer.start();

System.out.println("Consumer Started.");

}

}

NameServer和BrokerServer起来后，运行打印，把前面的不重要的去掉了，只看后面的几列：

content:2015-12-06 17:03:21 Hello RocketMQ 0

content:2015-12-06 17:03:21 Hello RocketMQ 1

content:2015-12-06 17:03:21 Hello RocketMQ 2

content:2015-12-06 17:03:21 Hello RocketMQ 3

content:2015-12-06 17:03:21 Hello RocketMQ 4

content:2015-12-06 17:03:21 Hello RocketMQ 5

content:2015-12-06 17:03:21 Hello RocketMQ 6

content:2015-12-06 17:03:21 Hello RocketMQ 7

content:2015-12-06 17:03:21 Hello RocketMQ 8

content:2015-12-06 17:03:21 Hello RocketMQ 9

可以看到，消息有序的。

java怎样将网页上面的数据以pdf的格式导出,求代码

需要用到一个pdf的jar包，去网上下载一个itextpdf.jar。导出pdf的格式都是需要自己用代码实现的，每一行 ，每一个列是什么格式，都需要自己写出来，是不能够自动生成的，反正很麻烦。我做的一个导出成pdf特定格式的东西，写了好几千行代码。相当头痛。

package com.dw.mqs.export;

import java.awt.Color;

import java.io.ByteArrayOutputStream;

import java.math.BigDecimal;

import java.net.URL;

import java.util.Date;

import java.util.HashSet;

import java.util.Hashtable;

import java.util.List;

import java.util.Map;

import java.util.Set;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import com.dw.file.WebHelper;

import com.dw.mqs.MqsManager;

import com.dw.mqs.MqsUtilNew;

import com.dw.mqs.ProductItem;

import com.dw.mqs.ProjectBasicItem;

import com.dw.mqs.ProjectConfDetailItem;

import com.dw.mqs.ProjectConfVerItem;

import com.dw.mqs.ProjectConfig;

import com.dw.mqs.ProjectService;

import com.dw.mqs.Util;

import com.dw.system.Convert;

import com.dw.system.gdb.DBResult;

import com.dw.system.gdb.DataRow;

import com.dw.system.gdb.GDB;

import com.dw.user.User;

import com.dw.user.UserManager;

import com.dw.user.UserProfile;

import com.lowagie.text.Document;

import com.lowagie.text.Element;

import com.lowagie.text.Font;

import com.lowagie.text.Image;

import com.lowagie.text.PageSize;

import com.lowagie.text.Paragraph;

import com.lowagie.text.Rectangle;

import com.lowagie.text.pdf.BaseFont;

import com.lowagie.text.pdf.PdfPCell;

import com.lowagie.text.pdf.PdfPTable;

import com.lowagie.text.pdf.PdfWriter;

public class PdfService

{

Document document = new Document(PageSize.A4.rotate(), 50, 50, 50, 50);

ByteArrayOutputStream os = new ByteArrayOutputStream();

PdfWriter pdf = PdfWriter.getInstance(document, os);

Rectangle rect = new Rectangle(36, 54, 559, 788);

pdf.setBoxSize("art", rect);

pdf.setPageEvent(new TableHeader());

document.open();

BaseFont baseArialuni = BaseFont.createFont("res/ARIALUNI.TTF",

BaseFont.IDENTITY_H, BaseFont.NOT_EMBEDDED); // Arial

// unicode字体

Font fontCN = new Font(baseArialuni, 9, Font.NORMAL, Color.BLACK);

Font fontCN8b = new Font(baseArialuni, 9, Font.BOLD, Color.BLACK);

Font fontCN12b = new Font(baseArialuni, 12, Font.BOLD, Color.BLACK);

Font fontCN9b = new Font(baseArialuni, 10, Font.BOLD, Color.BLACK);

Font fontCN9 = new Font(baseArialuni, 10, Font.NORMAL, Color.BLACK);

Font fontCN9b_blue = new Font(baseArialuni, 10, Font.BOLD, Color.BLUE);

PdfPTable table = null;

PdfPCell cell = null;

table = new PdfPTable(relativeWidths);

table.setWidthPercentage(100);

cell = new PdfPCell(new Paragraph(tit + "标题", fontCN12b));

cell.setColspan(root ? 12 : 10);

cell.setHorizontalAlignment(Element.ALIGN_CENTER); // 水平居中

cell.setVerticalAlignment(Element.ALIGN_MIDDLE); // 垂直居中

cell.setBorder(Rectangle.NO_BORDER);

table.addCell(cell);

}

mqsjava的介绍就聊到这里吧，感谢你花时间阅读本站内容，更多关于、mqsjava的信息别忘了在本站进行查找喔。