Explorar el Código

修复sonar扫描

liutong3 %!s(int64=5) %!d(string=hace) años
padre
commit
199b1dbd24

+ 6 - 2
comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaCustomerExample.java

@ -1,5 +1,7 @@
1 1
package com.ai.ipu.example.kafka;
2 2
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
3 5
import org.apache.kafka.clients.consumer.ConsumerConfig;
4 6
import org.apache.kafka.clients.consumer.ConsumerRecord;
5 7
import org.apache.kafka.clients.consumer.ConsumerRecords;
@ -8,6 +10,8 @@ import java.util.Arrays;
8 10
import java.util.Properties;
9 11
10 12
public class KafkaCustomerExample {
13
    private static final Log logger = LogFactory.getLog(KafkaCustomerExample.class);
14
11 15
    public static void main(String[] args) throws InterruptedException {
12 16
        Properties properties = new Properties();
13 17
        properties.put("bootstrap.servers", "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093");
@ -23,8 +27,8 @@ public class KafkaCustomerExample {
23 27
            while (true) {
24 28
                ConsumerRecords<String, String> records = kafkaConsumer.poll(100);
25 29
                for (ConsumerRecord<String, String> record : records) {
26
                    System.out.printf("offset = %d, value = %s", record.offset(), record.value());
27
                    System.out.println("\n=================================");
30
                    logger.debug("offset = " + record.offset() + ", value = " + record.value());
31
                    logger.debug("\n=================================");
28 32
                }
29 33
            }
30 34
        } finally {

+ 6 - 2
comp-example/src/test/java/com/ai/ipu/example/kafka/KafkaProducerExample.java

@ -1,5 +1,7 @@
1 1
package com.ai.ipu.example.kafka;
2 2
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
3 5
import org.apache.kafka.clients.producer.KafkaProducer;
4 6
import org.apache.kafka.clients.producer.ProducerRecord;
5 7
@ -9,6 +11,8 @@ import java.util.Properties;
9 11
import java.util.Scanner;
10 12
11 13
public class KafkaProducerExample {
14
    private static final Log logger = LogFactory.getLog(KafkaProducerExample.class);
15
12 16
    public static void main(String[] args){
13 17
        Properties properties = new Properties();
14 18
        properties.put("bootstrap.servers", "47.105.160.21:9091,47.105.160.21:9092,47.105.160.21:9093");
@ -21,10 +25,10 @@ public class KafkaProducerExample {
21 25
            int i = 0;
22 26
            while (true) {
23 27
                i++;
24
                System.out.println("请输入第" + i + "条信息的内容:");
28
                logger.debug("请输入第" + i + "条信息的内容:");
25 29
                String message = sc.nextLine();
26 30
                producer.send(new ProducerRecord<String, String>("test", message));
27
                System.out.println("Sent:" + message);
31
                logger.debug("Sent:" + message);
28 32
            }
29 33
        } finally {
30 34
            producer.close();

+ 7 - 2
comp-example/src/test/java/com/ai/ipu/example/rabbitmq/RabbitMQCustomerExample.java

@ -1,6 +1,8 @@
1 1
package com.ai.ipu.example.rabbitmq;
2 2
3 3
import com.rabbitmq.client.*;
4
import org.apache.commons.logging.Log;
5
import org.apache.commons.logging.LogFactory;
4 6
5 7
import java.io.IOException;
6 8
import java.util.concurrent.TimeoutException;
@ -14,6 +16,9 @@ import java.util.concurrent.TimeoutException;
14 16
public class RabbitMQCustomerExample {
15 17
    private final static String QUEUE_NAME = "rabbitMQ.test";
16 18
19
    private static final Log logger = LogFactory.getLog(RabbitMQCustomerExample.class);
20
21
17 22
    public static void main(String[] args) throws IOException, TimeoutException {
18 23
        // 创建连接工厂
19 24
        ConnectionFactory factory = new ConnectionFactory();
@ -35,8 +40,8 @@ public class RabbitMQCustomerExample {
35 40
                                       AMQP.BasicProperties properties, byte[] body)
36 41
                    throws IOException {
37 42
                String message = new String(body, "UTF-8");
38
                System.out.println("返回消息信息:");
39
                System.out.println(message);
43
                logger.debug("返回消息信息:");
44
                logger.debug(message);
40 45
            }
41 46
        };
42 47
        //自动回复队列应答 -- RabbitMQ中的消息确认机制

+ 6 - 2
comp-example/src/test/java/com/ai/ipu/example/rabbitmq/RabbitMQProducerExample.java

@ -3,6 +3,8 @@ package com.ai.ipu.example.rabbitmq;
3 3
import com.rabbitmq.client.Channel;
4 4
import com.rabbitmq.client.Connection;
5 5
import com.rabbitmq.client.ConnectionFactory;
6
import org.apache.commons.logging.Log;
7
import org.apache.commons.logging.LogFactory;
6 8
import org.apache.kafka.clients.producer.ProducerRecord;
7 9
8 10
import java.io.IOException;
@ -18,6 +20,8 @@ import java.util.concurrent.TimeoutException;
18 20
public class RabbitMQProducerExample {
19 21
    public final static String QUEUE_NAME="rabbitMQ.test";
20 22
23
    private static final Log logger = LogFactory.getLog(RabbitMQProducerExample.class);
24
21 25
    public static void main(String[] args) throws IOException, TimeoutException {
22 26
        //创建连接工厂
23 27
        ConnectionFactory factory = new ConnectionFactory();
@ -36,10 +40,10 @@ public class RabbitMQProducerExample {
36 40
            int i = 0;
37 41
            while (true) {
38 42
                i++;
39
                System.out.println("请输入第" + i + "条信息的内容:");
43
                logger.debug("请输入第" + i + "条信息的内容:");
40 44
                String message = sc.nextLine();
41 45
                channel.basicPublish("", QUEUE_NAME, null, message.getBytes("UTF-8"));
42
                System.out.println("Sent:" + message);
46
                logger.debug("Sent:" + message);
43 47
            }
44 48
        } finally {
45 49
            //关闭通道和连接

+ 9 - 5
comp-example/src/test/java/com/ai/ipu/example/rocketmq/RocketMQCustomerExample.java

@ -1,5 +1,7 @@
1 1
package com.ai.ipu.example.rocketmq;
2 2
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
3 5
import org.apache.rocketmq.client.consumer.DefaultMQPushConsumer;
4 6
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyContext;
5 7
import org.apache.rocketmq.client.consumer.listener.ConsumeConcurrentlyStatus;
@ -11,6 +13,8 @@ import org.apache.rocketmq.common.message.MessageExt;
11 13
import java.util.List;
12 14
13 15
public class RocketMQCustomerExample {
16
    private static final Log logger = LogFactory.getLog(RocketMQCustomerExample.class);
17
14 18
    public static void main(String[] args) throws MQClientException {
15 19
        DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("consumer1");
16 20
        consumer.setNamesrvAddr("47.105.160.21:9876");
@ -19,15 +23,15 @@ public class RocketMQCustomerExample {
19 23
        consumer.registerMessageListener(new MessageListenerConcurrently() {
20 24
            public ConsumeConcurrentlyStatus consumeMessage(List<MessageExt> messages,
21 25
                                                            ConsumeConcurrentlyContext context) {
22
                System.out.println("返回消息信息:");
23
                System.out.println(messages);
26
                logger.debug("返回消息信息:");
27
                logger.debug(messages);
24 28
                int j = 0;
25 29
                for (MessageExt message : messages) {
26 30
                    j++;
27
                    System.out.println("返回的第" + j + "条消息为:");
28
                    System.out.println(new String(message.getBody()));
31
                    logger.debug("返回的第" + j + "条消息为:");
32
                    logger.debug(new String(message.getBody()));
29 33
                }
30
                System.out.println("----------------------------------------------------------------------------------");
34
                logger.debug("----------------------------------------------------------------------------------");
31 35
                return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
32 36
            }
33 37
        });

+ 10 - 6
comp-example/src/test/java/com/ai/ipu/example/rocketmq/RocketMQProducerExample.java

@ -1,5 +1,7 @@
1 1
package com.ai.ipu.example.rocketmq;
2 2
3
import org.apache.commons.logging.Log;
4
import org.apache.commons.logging.LogFactory;
3 5
import org.apache.rocketmq.client.exception.MQBrokerException;
4 6
import org.apache.rocketmq.client.exception.MQClientException;
5 7
import org.apache.rocketmq.client.producer.DefaultMQProducer;
@ -12,6 +14,8 @@ import java.io.UnsupportedEncodingException;
12 14
import java.util.Scanner;
13 15
14 16
public class RocketMQProducerExample {
17
    private static final Log logger = LogFactory.getLog(RocketMQProducerExample.class);
18
15 19
    public static void main(String[] args) throws MQClientException, InterruptedException {
16 20
        DefaultMQProducer producer = new DefaultMQProducer("producer1");
17 21
        producer.setVipChannelEnabled(false);
@ -24,22 +28,22 @@ public class RocketMQProducerExample {
24 28
            int i = 0;
25 29
            while (true) {
26 30
                i++;
27
                System.out.println("请输入第" + i + "条信息的内容:");
31
                logger.debug("请输入第" + i + "条信息的内容:");
28 32
                String message = sc.nextLine();
29 33
                Message msg = new Message("testTopic",
30 34
                        "testTag",
31 35
                        message.getBytes(RemotingHelper.DEFAULT_CHARSET)
32 36
                );
33 37
                SendResult sendResult = producer.send(msg);
34
                System.out.println("发出消息信息:");
35
                System.out.println(sendResult);
38
                logger.debug("发出消息信息:");
39
                logger.debug(sendResult);
36 40
            }
37 41
        } catch (RemotingException e) {
38
            e.printStackTrace();
42
            logger.error(e.getMessage(), e);
39 43
        } catch (MQBrokerException e) {
40
            e.printStackTrace();
44
            logger.error(e.getMessage(), e);
41 45
        } catch (UnsupportedEncodingException e) {
42
            e.printStackTrace();
46
            logger.error(e.getMessage(), e);
43 47
        } finally {
44 48
            producer.shutdown();
45 49
        }