Merge branch 'wvp-28181-2.0' into 结构优化
# Conflicts: # src/main/java/com/genersoft/iot/vmp/storager/dao/StreamPushMapper.java结构优化
commit
fb39e4ff0e
|
@ -29,12 +29,12 @@ public class WvpRedisMsg {
|
||||||
* 消息的ID
|
* 消息的ID
|
||||||
*/
|
*/
|
||||||
private String serial;
|
private String serial;
|
||||||
private Object content;
|
private String content;
|
||||||
|
|
||||||
private final static String requestTag = "req";
|
private final static String requestTag = "req";
|
||||||
private final static String responseTag = "res";
|
private final static String responseTag = "res";
|
||||||
|
|
||||||
public static WvpRedisMsg getRequestInstance(String fromId, String toId, String cmd, String serial, Object content) {
|
public static WvpRedisMsg getRequestInstance(String fromId, String toId, String cmd, String serial, String content) {
|
||||||
WvpRedisMsg wvpRedisMsg = new WvpRedisMsg();
|
WvpRedisMsg wvpRedisMsg = new WvpRedisMsg();
|
||||||
wvpRedisMsg.setType(requestTag);
|
wvpRedisMsg.setType(requestTag);
|
||||||
wvpRedisMsg.setFromId(fromId);
|
wvpRedisMsg.setFromId(fromId);
|
||||||
|
@ -51,7 +51,7 @@ public class WvpRedisMsg {
|
||||||
return wvpRedisMsg;
|
return wvpRedisMsg;
|
||||||
}
|
}
|
||||||
|
|
||||||
public static WvpRedisMsg getResponseInstance(String fromId, String toId, String cmd, String serial, Object content) {
|
public static WvpRedisMsg getResponseInstance(String fromId, String toId, String cmd, String serial, String content) {
|
||||||
WvpRedisMsg wvpRedisMsg = new WvpRedisMsg();
|
WvpRedisMsg wvpRedisMsg = new WvpRedisMsg();
|
||||||
wvpRedisMsg.setType(responseTag);
|
wvpRedisMsg.setType(responseTag);
|
||||||
wvpRedisMsg.setFromId(fromId);
|
wvpRedisMsg.setFromId(fromId);
|
||||||
|
@ -106,11 +106,11 @@ public class WvpRedisMsg {
|
||||||
this.cmd = cmd;
|
this.cmd = cmd;
|
||||||
}
|
}
|
||||||
|
|
||||||
public Object getContent() {
|
public String getContent() {
|
||||||
return content;
|
return content;
|
||||||
}
|
}
|
||||||
|
|
||||||
public void setContent(Object content) {
|
public void setContent(String content) {
|
||||||
this.content = content;
|
this.content = content;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -113,8 +113,8 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
while (!taskQueue.isEmpty()) {
|
while (!taskQueue.isEmpty()) {
|
||||||
Message msg = taskQueue.poll();
|
Message msg = taskQueue.poll();
|
||||||
try {
|
try {
|
||||||
JSONObject msgJSON = JSON.parseObject(msg.getBody(), JSONObject.class);
|
WvpRedisMsg wvpRedisMsg = JSON.parseObject(msg.getBody(), WvpRedisMsg.class);
|
||||||
WvpRedisMsg wvpRedisMsg = JSON.to(WvpRedisMsg.class, msgJSON);
|
logger.info("[收到REDIS通知] 消息: {}", JSON.toJSONString(wvpRedisMsg));
|
||||||
if (!userSetting.getServerId().equals(wvpRedisMsg.getToId())) {
|
if (!userSetting.getServerId().equals(wvpRedisMsg.getToId())) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
@ -123,7 +123,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
|
|
||||||
switch (wvpRedisMsg.getCmd()){
|
switch (wvpRedisMsg.getCmd()){
|
||||||
case WvpRedisMsgCmd.GET_SEND_ITEM:
|
case WvpRedisMsgCmd.GET_SEND_ITEM:
|
||||||
RequestSendItemMsg content = JSON.to(RequestSendItemMsg.class, wvpRedisMsg.getContent());
|
RequestSendItemMsg content = JSON.parseObject(wvpRedisMsg.getContent(), RequestSendItemMsg.class);
|
||||||
requestSendItemMsgHand(content, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
|
requestSendItemMsgHand(content, wvpRedisMsg.getFromId(), wvpRedisMsg.getSerial());
|
||||||
break;
|
break;
|
||||||
case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
|
case WvpRedisMsgCmd.REQUEST_PUSH_STREAM:
|
||||||
|
@ -242,7 +242,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
result.setData(content);
|
result.setData(content);
|
||||||
|
|
||||||
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(userSetting.getServerId(), toId,
|
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(userSetting.getServerId(), toId,
|
||||||
WvpRedisMsgCmd.REQUEST_PUSH_STREAM, serial, result);
|
WvpRedisMsgCmd.REQUEST_PUSH_STREAM, serial, JSON.toJSONString(result));
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
||||||
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
||||||
}
|
}
|
||||||
|
@ -260,7 +260,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
result.setMsg("流媒体不存在");
|
result.setMsg("流媒体不存在");
|
||||||
|
|
||||||
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(userSetting.getServerId(), toId,
|
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(userSetting.getServerId(), toId,
|
||||||
WvpRedisMsgCmd.GET_SEND_ITEM, serial, result);
|
WvpRedisMsgCmd.GET_SEND_ITEM, serial, JSON.toJSONString(result));
|
||||||
|
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
||||||
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
||||||
|
@ -283,7 +283,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
WVPResult<SendRtpItem> result = new WVPResult<>();
|
WVPResult<SendRtpItem> result = new WVPResult<>();
|
||||||
result.setCode(ERROR_CODE_TIMEOUT);
|
result.setCode(ERROR_CODE_TIMEOUT);
|
||||||
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(
|
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(
|
||||||
userSetting.getServerId(), toId, WvpRedisMsgCmd.GET_SEND_ITEM, serial, result
|
userSetting.getServerId(), toId, WvpRedisMsgCmd.GET_SEND_ITEM, serial, JSON.toJSONString(result)
|
||||||
);
|
);
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
||||||
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
||||||
|
@ -324,7 +324,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
result.setData(responseSendItemMsg);
|
result.setData(responseSendItemMsg);
|
||||||
|
|
||||||
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(
|
WvpRedisMsg response = WvpRedisMsg.getResponseInstance(
|
||||||
userSetting.getServerId(), toId, WvpRedisMsgCmd.GET_SEND_ITEM, serial, result
|
userSetting.getServerId(), toId, WvpRedisMsgCmd.GET_SEND_ITEM, serial, JSON.toJSONString(result)
|
||||||
);
|
);
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(response);
|
||||||
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
redisTemplate.convertAndSend(WVP_PUSH_STREAM_KEY, jsonObject);
|
||||||
|
@ -350,7 +350,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
requestSendItemMsg.setServerId(serverId);
|
requestSendItemMsg.setServerId(serverId);
|
||||||
String key = UUID.randomUUID().toString();
|
String key = UUID.randomUUID().toString();
|
||||||
WvpRedisMsg redisMsg = WvpRedisMsg.getRequestInstance(userSetting.getServerId(), serverId, WvpRedisMsgCmd.GET_SEND_ITEM,
|
WvpRedisMsg redisMsg = WvpRedisMsg.getRequestInstance(userSetting.getServerId(), serverId, WvpRedisMsgCmd.GET_SEND_ITEM,
|
||||||
key, requestSendItemMsg);
|
key, JSON.toJSONString(requestSendItemMsg));
|
||||||
|
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(redisMsg);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(redisMsg);
|
||||||
logger.info("[请求推流SendItem] {}: {}", serverId, jsonObject);
|
logger.info("[请求推流SendItem] {}: {}", serverId, jsonObject);
|
||||||
|
@ -375,7 +375,7 @@ public class RedisGbPlayMsgListener implements MessageListener {
|
||||||
public void sendMsgForStartSendRtpStream(String serverId, RequestPushStreamMsg param, PlayMsgCallbackForStartSendRtpStream callback) {
|
public void sendMsgForStartSendRtpStream(String serverId, RequestPushStreamMsg param, PlayMsgCallbackForStartSendRtpStream callback) {
|
||||||
String key = UUID.randomUUID().toString();
|
String key = UUID.randomUUID().toString();
|
||||||
WvpRedisMsg redisMsg = WvpRedisMsg.getRequestInstance(userSetting.getServerId(), serverId,
|
WvpRedisMsg redisMsg = WvpRedisMsg.getRequestInstance(userSetting.getServerId(), serverId,
|
||||||
WvpRedisMsgCmd.REQUEST_PUSH_STREAM, key, param);
|
WvpRedisMsgCmd.REQUEST_PUSH_STREAM, key, JSON.toJSONString(param));
|
||||||
|
|
||||||
JSONObject jsonObject = (JSONObject)JSON.toJSON(redisMsg);
|
JSONObject jsonObject = (JSONObject)JSON.toJSON(redisMsg);
|
||||||
logger.info("[REDIS 请求其他平台推流] {}: {}", serverId, jsonObject);
|
logger.info("[REDIS 请求其他平台推流] {}: {}", serverId, jsonObject);
|
||||||
|
|
|
@ -14,9 +14,9 @@ import java.util.Map;
|
||||||
public interface StreamPushMapper {
|
public interface StreamPushMapper {
|
||||||
|
|
||||||
@Insert("INSERT INTO wvp_stream_push (name, app, stream, common_gb_channel_id, gb_id, longitude, latitude, " +
|
@Insert("INSERT INTO wvp_stream_push (name, app, stream, common_gb_channel_id, gb_id, longitude, latitude, " +
|
||||||
"push_time, media_server_id, update_time, create_time, push_ing, self, status) VALUES" +
|
"push_time, media_server_id, server_id, update_time, create_time, push_ing, self, status) VALUES" +
|
||||||
"(#{name}, #{app}, #{stream}, #{commonGbChannelId}, #{gbId},#{longitude},#{latitude}, " +
|
"(#{name}, #{app}, #{stream}, #{commonGbChannelId}, #{gbId},#{longitude},#{latitude}, " +
|
||||||
"#{pushTime}, #{mediaServerId} , #{updateTime} , #{createTime}, #{pushIng}, #{self}, #{status} )")
|
"#{pushTime}, #{mediaServerId} , #{serverId}, #{updateTime} , #{createTime}, #{pushIng}, #{self}, #{status} )")
|
||||||
int add(StreamPush streamPushItem);
|
int add(StreamPush streamPushItem);
|
||||||
|
|
||||||
|
|
||||||
|
@ -25,6 +25,7 @@ public interface StreamPushMapper {
|
||||||
"SET update_time=#{updateTime}" +
|
"SET update_time=#{updateTime}" +
|
||||||
"<if test=\"name != null\">, name=#{name}</if>" +
|
"<if test=\"name != null\">, name=#{name}</if>" +
|
||||||
"<if test=\"mediaServerId != null\">, media_server_id=#{mediaServerId}</if>" +
|
"<if test=\"mediaServerId != null\">, media_server_id=#{mediaServerId}</if>" +
|
||||||
|
"<if test=\"serverId != null\">, server_id=#{serverId}</if>" +
|
||||||
"<if test=\"commonGbChannelId != null\">, common_gb_channel_id=#{commonGbChannelId}</if>" +
|
"<if test=\"commonGbChannelId != null\">, common_gb_channel_id=#{commonGbChannelId}</if>" +
|
||||||
"<if test=\"gbId != null\">, gb_id=#{gbId}</if>" +
|
"<if test=\"gbId != null\">, gb_id=#{gbId}</if>" +
|
||||||
"<if test=\"longitude != null\">, longitude=#{longitude}</if>" +
|
"<if test=\"longitude != null\">, longitude=#{longitude}</if>" +
|
||||||
|
@ -85,10 +86,10 @@ public interface StreamPushMapper {
|
||||||
|
|
||||||
@Insert("<script>" +
|
@Insert("<script>" +
|
||||||
"Insert INTO wvp_stream_push (name, app, stream, common_gb_channel_id, gb_id, longitude, " +
|
"Insert INTO wvp_stream_push (name, app, stream, common_gb_channel_id, gb_id, longitude, " +
|
||||||
"latitude, create_time, media_server_id, status, push_ing) " +
|
"latitude, create_time, media_server_id, server_id, status, push_ing) " +
|
||||||
"VALUES <foreach collection='streamPushItems' item='item' index='index' separator=','>" +
|
"VALUES <foreach collection='streamPushItems' item='item' index='index' separator=','>" +
|
||||||
"(#{item.name}, #{item.app}, #{item.stream}, #{item.commonGbChannelId}, #{item.gbId},#{item.longitude}, " +
|
"(#{item.name}, #{item.app}, #{item.stream}, #{item.commonGbChannelId}, #{item.gbId},#{item.longitude}, " +
|
||||||
"#{item.latitude}, #{item.createTime}, #{item.mediaServerId}, #{item.status}, #{item.pushIng} )" +
|
"#{item.latitude}, #{item.createTime}, #{item.mediaServerId}, #{item.serverId}, #{item.status}, #{item.pushIng} )" +
|
||||||
" </foreach>" +
|
" </foreach>" +
|
||||||
"</script>")
|
"</script>")
|
||||||
@Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
|
@Options(useGeneratedKeys = true, keyProperty = "id", keyColumn = "id")
|
||||||
|
|
|
@ -261,6 +261,7 @@ create table wvp_stream_push (
|
||||||
create_time character varying(50),
|
create_time character varying(50),
|
||||||
alive_second integer,
|
alive_second integer,
|
||||||
media_server_id character varying(50),
|
media_server_id character varying(50),
|
||||||
|
server_id character varying(50),
|
||||||
push_time character varying(50),
|
push_time character varying(50),
|
||||||
status bool default false,
|
status bool default false,
|
||||||
update_time character varying(50),
|
update_time character varying(50),
|
||||||
|
|
|
@ -261,6 +261,7 @@ create table wvp_stream_push (
|
||||||
create_time character varying(50),
|
create_time character varying(50),
|
||||||
alive_second integer,
|
alive_second integer,
|
||||||
media_server_id character varying(50),
|
media_server_id character varying(50),
|
||||||
|
server_id character varying(50),
|
||||||
push_time character varying(50),
|
push_time character varying(50),
|
||||||
status bool default false,
|
status bool default false,
|
||||||
update_time character varying(50),
|
update_time character varying(50),
|
||||||
|
|
|
@ -497,4 +497,7 @@ alter table wvp_media_server
|
||||||
alter table wvp_media_server
|
alter table wvp_media_server
|
||||||
add record_day integer default 7;
|
add record_day integer default 7;
|
||||||
|
|
||||||
|
alter table wvp_stream_push
|
||||||
|
add server_id character varying(50);
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -498,5 +498,8 @@ alter table wvp_media_server
|
||||||
alter table wvp_media_server
|
alter table wvp_media_server
|
||||||
add record_day integer default 7;
|
add record_day integer default 7;
|
||||||
|
|
||||||
|
alter table wvp_stream_push
|
||||||
|
add server_id character varying(50);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -261,6 +261,7 @@ create table wvp_stream_push (
|
||||||
create_time character varying(50),
|
create_time character varying(50),
|
||||||
alive_second integer,
|
alive_second integer,
|
||||||
media_server_id character varying(50),
|
media_server_id character varying(50),
|
||||||
|
server_id character varying(50),
|
||||||
push_time character varying(50),
|
push_time character varying(50),
|
||||||
status bool default false,
|
status bool default false,
|
||||||
update_time character varying(50),
|
update_time character varying(50),
|
||||||
|
|
|
@ -229,6 +229,7 @@ create table wvp_stream_push (
|
||||||
create_time character varying(50),
|
create_time character varying(50),
|
||||||
alive_second integer,
|
alive_second integer,
|
||||||
media_server_id character varying(50),
|
media_server_id character varying(50),
|
||||||
|
server_id character varying(50),
|
||||||
push_time character varying(50),
|
push_time character varying(50),
|
||||||
status bool default false,
|
status bool default false,
|
||||||
update_time character varying(50),
|
update_time character varying(50),
|
||||||
|
|
Loading…
Reference in New Issue