调试七牛云OSS

master
3y 2 years ago
parent 34a3d04f1d
commit 19b74900dd

@ -154,7 +154,7 @@ public class PushHandler extends BaseHandler implements Handler {
SendPushParam param = SendPushParam.builder()
.requestId(String.valueOf(IdUtil.getSnowflake().nextId()))
.pushMessage(SendPushParam.PushMessageVO.builder().notification(SendPushParam.PushMessageVO.NotificationVO.builder()
.title(pushContentModel.getTitle()).body(pushContentModel.getContent()).clickType("startapp").build())
.title(pushContentModel.getTitle()).body(pushContentModel.getContent()).clickType("startapp").build())
.build())
.build();
if (CollUtil.isNotEmpty(cid)) {

@ -4,7 +4,7 @@ import com.alibaba.fastjson.JSON;
import com.java3y.austin.common.domain.TaskInfo;
import com.java3y.austin.support.constans.MessageQueuePipeline;
import com.java3y.austin.support.domain.MessageTemplate;
import com.java3y.austin.support.mq.springeventbus.SpringEventBusEvent;
import com.java3y.austin.support.mq.springeventbus.AustinSpringEventBusEvent;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
@ -19,7 +19,7 @@ import org.springframework.stereotype.Service;
*/
@Service
@ConditionalOnProperty(name = "austin.mq.pipeline", havingValue = MessageQueuePipeline.SPRING_EVENT_BUS)
public class SpringEventBusReceiverListener implements ApplicationListener<SpringEventBusEvent> {
public class SpringEventBusReceiverListener implements ApplicationListener<AustinSpringEventBusEvent> {
@Autowired
private SpringEventBusReceiver springEventBusReceiver;
@ -30,9 +30,9 @@ public class SpringEventBusReceiverListener implements ApplicationListener<Sprin
private String recallTopic;
@Override
public void onApplicationEvent(SpringEventBusEvent event) {
String topic = event.getTopic();
String jsonValue = event.getJsonValue();
public void onApplicationEvent(AustinSpringEventBusEvent event) {
String topic = event.getAustinSpringEventSource().getTopic();
String jsonValue = event.getAustinSpringEventSource().getJsonValue();
if (topic.equals(sendTopic)) {
springEventBusReceiver.consume(JSON.parseArray(jsonValue, TaskInfo.class));
} else if (topic.equals(recallTopic)) {

@ -51,7 +51,7 @@ public class ShieldServiceImpl implements ShieldService {
}
if (ShieldType.NIGHT_SHIELD_BUT_NEXT_DAY_SEND.getCode().equals(taskInfo.getShieldType())) {
redisUtils.lPush(NIGHT_SHIELD_BUT_NEXT_DAY_SEND_KEY, JSON.toJSONString(taskInfo,
SerializerFeature.WriteClassName),
SerializerFeature.WriteClassName),
(DateUtil.offsetDay(new Date(), 1).getTime() / 1000) - DateUtil.currentSeconds());
logUtils.print(AnchorInfo.builder().state(AnchorState.NIGHT_SHIELD_NEXT_SEND.getCode()).businessId(taskInfo.getBusinessId()).ids(taskInfo.getReceiver()).build());
}

@ -118,7 +118,10 @@
<groupId>com.github.binarywang</groupId>
<artifactId>weixin-java-miniapp</artifactId>
</dependency>
<dependency>
<groupId>com.qiniu</groupId>
<artifactId>qiniu-java-sdk</artifactId>
</dependency>
</dependencies>
</project>

@ -11,7 +11,6 @@ public interface MessageQueuePipeline {
String KAFKA = "kafka";
String ROCKET_MQ = "rocketMq";
String RABBIT_MQ = "rabbitMq";
String SPRING_EVENT_BUS ="springEventBus";
String SPRING_EVENT_BUS = "springEventBus";
}

@ -0,0 +1,22 @@
package com.java3y.austin.support.mq.springeventbus;
import lombok.Getter;
import org.springframework.context.ApplicationEvent;
/**
*
*
* @author tony
* @date 2023/2/6 19:59
*/
@Getter
public class AustinSpringEventBusEvent extends ApplicationEvent {
private AustinSpringEventSource austinSpringEventSource;
public AustinSpringEventBusEvent(Object source, AustinSpringEventSource austinSpringEventSource) {
super(source);
this.austinSpringEventSource = austinSpringEventSource;
}
}

@ -0,0 +1,15 @@
package com.java3y.austin.support.mq.springeventbus;
import lombok.Builder;
import lombok.Data;
/**
* @author 3y
*/
@Data
@Builder
public class AustinSpringEventSource {
public String topic;
public String jsonValue;
public String tagId;
}

@ -1,18 +0,0 @@
package com.java3y.austin.support.mq.springeventbus;
import lombok.Data;
import org.springframework.context.ApplicationEvent;
/**
*
*
* @author tony
* @date 2023/2/6 19:59
*/
@Data
public class SpringEventBusEvent extends ApplicationEvent {
public String topic;
public String jsonValue;
public String tagId;
}

@ -25,15 +25,13 @@ public class SpringEventBusSendMqServiceImpl implements SendMqService {
@Override
public void send(String topic, String jsonValue, String tagId) {
SpringEventBusEvent springEventBusEvent = new SpringEventBusEvent();
springEventBusEvent.setTopic(topic);
springEventBusEvent.setJsonValue(jsonValue);
springEventBusEvent.setTagId(tagId);
applicationContext.publishEvent(springEventBusEvent);
AustinSpringEventSource source = AustinSpringEventSource.builder().topic(topic).jsonValue(jsonValue).tagId(tagId).build();
AustinSpringEventBusEvent austinSpringEventBusEvent = new AustinSpringEventBusEvent(this, source);
applicationContext.publishEvent(austinSpringEventBusEvent);
}
@Override
public void send(String topic, String jsonValue) {
send(topic,jsonValue,null);
send(topic, jsonValue, null);
}
}

@ -70,9 +70,9 @@ public class AccountUtils {
if (optionalChannelAccount.isPresent()) {
ChannelAccount channelAccount = optionalChannelAccount.get();
if (clazz.equals(WxMaService.class)) {
return (T)ConcurrentHashMapUtils.computeIfAbsent(miniProgramServiceMap, channelAccount, account -> initMiniProgramService(JSON.parseObject(account.getAccountConfig(), WeChatMiniProgramAccount.class)));
return (T) ConcurrentHashMapUtils.computeIfAbsent(miniProgramServiceMap, channelAccount, account -> initMiniProgramService(JSON.parseObject(account.getAccountConfig(), WeChatMiniProgramAccount.class)));
} else if (clazz.equals(WxMpService.class)) {
return (T)ConcurrentHashMapUtils.computeIfAbsent(officialAccountServiceMap, channelAccount, account -> initOfficialAccountService(JSON.parseObject(account.getAccountConfig(), WeChatOfficialAccount.class)));
return (T) ConcurrentHashMapUtils.computeIfAbsent(officialAccountServiceMap, channelAccount, account -> initOfficialAccountService(JSON.parseObject(account.getAccountConfig(), WeChatOfficialAccount.class)));
} else {
return JSON.parseObject(channelAccount.getAccountConfig(), clazz);
}
@ -143,5 +143,4 @@ public class AccountUtils {
}
}

@ -24,8 +24,8 @@ public class ConcurrentHashMapUtils {
/**
* Java 8 ConcurrentHashMap#computeIfAbsent
* @see <a href="https://bugs.openjdk.java.net/browse/JDK-8161372">https://bugs.openjdk.java.net/browse/JDK-8161372</a>
*
* @see <a href="https://bugs.openjdk.java.net/browse/JDK-8161372">https://bugs.openjdk.java.net/browse/JDK-8161372</a>
*/
public static <K, V> V computeIfAbsent(ConcurrentMap<K, V> map, K key, Function<? super K, ? extends V> func) {
if (IS_JAVA8) {

@ -0,0 +1,72 @@
package com.java3y.austin.support.utils;
import cn.hutool.core.util.IdUtil;
import com.alibaba.fastjson.JSON;
import com.qiniu.common.QiniuException;
import com.qiniu.http.Response;
import com.qiniu.storage.Configuration;
import com.qiniu.storage.Region;
import com.qiniu.storage.UploadManager;
import com.qiniu.storage.model.DefaultPutRet;
import com.qiniu.util.Auth;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
/**
* @author 3y
* @description
*/
public class OssUtils {
public static void main(String[] args) throws UnsupportedEncodingException {
//upload();
String fmnBLE4QtkwlErXIAh9pYS029GZk = getFileUrl("FmnBLE4QtkwlErXIAh9pYS029GZk");
System.out.println(fmnBLE4QtkwlErXIAh9pYS029GZk);
}
private static void upload() {
//构造一个带指定 Region 对象的配置类
Configuration cfg = new Configuration(Region.autoRegion());
cfg.resumableUploadAPIVersion = Configuration.ResumableUploadAPIVersion.V2;// 指定分片上传版本
//...其他参数参考类注释
UploadManager uploadManager = new UploadManager(cfg);
//...生成上传凭证,然后准备上传
String accessKey = "123";
String secretKey = "123";
String bucket = "austin3y";
//如果是Windows情况下格式是 D:\\qiniu\\test.png
String localFilePath = "C:\\Users\\zhongfucheng\\Desktop\\1201.jpg";
//默认不指定key的情况下以文件内容的hash值作为文件名
String key = IdUtil.fastSimpleUUID();
Auth auth = Auth.create(accessKey, secretKey);
String upToken = auth.uploadToken(bucket);
try {
Response response = uploadManager.put(localFilePath, key, upToken);
DefaultPutRet putRet = JSON.parseObject(response.bodyString(), DefaultPutRet.class);
//解析上传成功的结果
System.out.println(putRet.key);
System.out.println(putRet.hash);
} catch (QiniuException ex) {
Response r = ex.response;
System.err.println(r.toString());
try {
System.err.println(r.bodyString());
} catch (QiniuException ex2) {
//ignore
}
}
}
public static String getFileUrl(String fileName) throws UnsupportedEncodingException {
String domainOfBucket = "http://devtools.qiniu.com/austin3y";
String encodedFileName = URLEncoder.encode(fileName, "utf-8").replace("+", "%20");
String finalUrl = String.format("%s/%s", domainOfBucket, encodedFileName);
System.out.println(finalUrl);
return finalUrl;
}
}

@ -210,12 +210,19 @@
<version>2.0.0</version>
</dependency>
<!--rocketmq-->
<dependency>
<groupId>org.apache.rocketmq</groupId>
<artifactId>rocketmq-spring-boot-starter</artifactId>
<version>2.2.2</version>
</dependency>
<!--七牛云 SDK OSS-->
<dependency>
<groupId>com.qiniu</groupId>
<artifactId>qiniu-java-sdk</artifactId>
<version>[7.7.0, 7.10.99]</version>
</dependency>
</dependencies>
</dependencyManagement>

Loading…
Cancel
Save