[*] 结构调整

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/live/Live.java

@@ -0,0 +1,59 @@
+package com.acgist.taoyao.media.live;
+
+import java.util.List;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 直播
+ * 
+ * @author acgist
+ */
+@Getter
+@Setter
+@Schema(title = "直播", description = "直播")
+public class Live {
+	
+	/**
+	 * 直播标识
+	 */
+	@Schema(title = "直播标识", description = "直播标识")
+	private String id;
+	/**
+	 * 直播名称
+	 */
+	@Schema(title = "直播名称", description = "直播名称")
+	private String name;
+	/**
+	 * 直播密码
+	 */
+	@Schema(title = "直播密码", description = "直播密码")
+	private String password;
+	/**
+	 * 终端会话标识列表
+	 */
+	@Schema(title = "终端会话标识列表", description = "终端会话标识列表")
+	private List<String> sns;
+	/**
+	 * 创建终端标识
+	 */
+	@Schema(title = "创建终端标识", description = "创建终端标识")
+	private String creator;
+	
+	/**
+	 * 新增终端会话标识
+	 * 
+	 * @param sn 终端会话标识
+	 */
+	public void addSn(String sn) {
+		synchronized (this.sns) {
+			if(this.sns.contains(sn)) {
+				return;
+			}
+			this.sns.add(sn);
+		}
+	}
+
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/live/LiveListenerAdapter.java

@@ -0,0 +1,20 @@
+package com.acgist.taoyao.media.live;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.acgist.taoyao.signal.event.ApplicationEventAdapter;
+import com.acgist.taoyao.signal.listener.ApplicationListenerAdapter;
+
+/**
+ * 直播事件监听适配器
+ *
+ * @param <E> 事件泛型
+ * 
+ * @author acgist
+ */
+public abstract class LiveListenerAdapter<E extends ApplicationEventAdapter> extends ApplicationListenerAdapter<E> {
+
+	@Autowired
+	protected LiveManager liveManager;
+	
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/live/LiveManager.java

@@ -0,0 +1,13 @@
+package com.acgist.taoyao.media.live;
+
+import com.acgist.taoyao.boot.annotation.Manager;
+
+/**
+ * 直播管理
+ * 
+ * @author acgist
+ */
+@Manager
+public class LiveManager {
+
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/live/controller/LiveController.java

@@ -0,0 +1,46 @@
+package com.acgist.taoyao.media.live.controller;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.acgist.taoyao.boot.model.Message;
+import com.acgist.taoyao.media.live.Live;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+/**
+ * 直播
+ * 
+ * @author acgist
+ */
+@Tag(name = "直播", description = "直播管理")
+@RestController
+@RequestMapping("/live")
+public class LiveController {
+
+	@Operation(summary = "直播列表", description = "直播列表")
+	@GetMapping("/list")
+	@ApiResponse(content = @Content(schema = @Schema(implementation = Live.class)))
+	public Message list() {
+		return Message.success();
+	}
+	
+	@Operation(summary = "直播状态", description = "直播状态")
+	@GetMapping("/status/{id}")
+	public Message status(@PathVariable String id) {
+		return Message.success();
+	}
+	
+	@Operation(summary = "直播终端列表", description = "直播终端列表")
+	@GetMapping("/list/client")
+	public Message listClient() {
+		return Message.success();
+	}
+	
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/Meeting.java

@@ -0,0 +1,59 @@
+package com.acgist.taoyao.media.meeting;
+
+import java.util.List;
+
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Getter;
+import lombok.Setter;
+
+/**
+ * 会议
+ * 
+ * @author acgist
+ */
+@Getter
+@Setter
+@Schema(title = "会议", description = "会议")
+public class Meeting {
+	
+	/**
+	 * 会议标识
+	 */
+	@Schema(title = "会议标识", description = "会议标识")
+	private String id;
+	/**
+	 * 会议名称
+	 */
+	@Schema(title = "会议名称", description = "会议名称")
+	private String name;
+	/**
+	 * 会议密码
+	 */
+	@Schema(title = "会议密码", description = "会议密码")
+	private String password;
+	/**
+	 * 终端会话标识列表
+	 */
+	@Schema(title = "终端会话标识列表", description = "终端会话标识列表")
+	private List<String> sns;
+	/**
+	 * 创建终端标识
+	 */
+	@Schema(title = "创建终端标识", description = "创建终端标识")
+	private String creator;
+	
+	/**
+	 * 新增终端会话标识
+	 * 
+	 * @param sn 终端会话标识
+	 */
+	public void addSn(String sn) {
+		synchronized (this.sns) {
+			if(this.sns.contains(sn)) {
+				return;
+			}
+			this.sns.add(sn);
+		}
+	}
+
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/MeetingListenerAdapter.java

@@ -0,0 +1,20 @@
+package com.acgist.taoyao.media.meeting;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.acgist.taoyao.signal.event.ApplicationEventAdapter;
+import com.acgist.taoyao.signal.listener.ApplicationListenerAdapter;
+
+/**
+ * 会议事件监听适配器
+ *
+ * @param <E> 事件泛型
+ * 
+ * @author acgist
+ */
+public abstract class MeetingListenerAdapter<E extends ApplicationEventAdapter> extends ApplicationListenerAdapter<E> {
+
+	@Autowired
+	protected MeetingManager meetingManager;
+	
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/MeetingManager.java

@@ -0,0 +1,77 @@
+package com.acgist.taoyao.media.meeting;
+
+import java.util.List;
+import java.util.concurrent.CopyOnWriteArrayList;
+
+import org.springframework.beans.factory.annotation.Autowired;
+
+import com.acgist.taoyao.boot.annotation.Manager;
+import com.acgist.taoyao.boot.service.IdService;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 会议管理
+ * 
+ * @author acgist
+ */
+@Slf4j
+@Manager
+public class MeetingManager {
+
+	@Autowired
+	private IdService idService;
+
+	/**
+	 * 会议列表
+	 */
+	private List<Meeting> meetings = new CopyOnWriteArrayList<>();
+	
+	/**
+	 * @return 所有会议列表
+	 */
+	public List<Meeting> meetings() {
+		return this.meetings;
+	}
+	
+	/**
+	 * @param id 会议标识
+	 * 
+	 * @return 会议信息
+	 */
+	public Meeting meeting(String id) {
+		return this.meetings.stream()
+			.filter(v -> v.getId().equals(id))
+			.findFirst()
+			.orElse(null);
+	}
+
+	/**
+	 * @param id 会议标识
+	 * 
+	 * @return 会议所有终端标识
+	 */
+	public List<String> sns(String id) {
+		final Meeting meeting = this.meeting(id);
+		return meeting == null ? List.of() : meeting.getSns();
+	}
+
+	/**
+	 * 创建会议
+	 * 
+	 * @param sn 创建会议终端标识
+	 * 
+	 * @return 会议信息
+	 */
+	public Meeting create(String sn) {
+		final Meeting meeting = new Meeting();
+		meeting.setId(this.idService.buildIdToString());
+		meeting.setSns(new CopyOnWriteArrayList<>());
+		meeting.setCreator(sn);
+		meeting.addSn(sn);
+		this.meetings.add(meeting);
+		log.info("创建会议：{}", meeting.getId());
+		return meeting;
+	}
+	
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/controller/MeetingController.java

@@ -0,0 +1,51 @@
+package com.acgist.taoyao.media.meeting.controller;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import com.acgist.taoyao.boot.model.Message;
+import com.acgist.taoyao.media.meeting.Meeting;
+import com.acgist.taoyao.media.meeting.MeetingManager;
+
+import io.swagger.v3.oas.annotations.Operation;
+import io.swagger.v3.oas.annotations.media.Content;
+import io.swagger.v3.oas.annotations.media.Schema;
+import io.swagger.v3.oas.annotations.responses.ApiResponse;
+import io.swagger.v3.oas.annotations.tags.Tag;
+
+/**
+ * 会议
+ * 
+ * @author acgist
+ */
+@Tag(name = "会议", description = "会议管理")
+@RestController
+@RequestMapping("/meeting")
+public class MeetingController {
+	
+	@Autowired
+	private MeetingManager meetingManager;
+	
+	@Operation(summary = "会议列表", description = "会议列表")
+	@GetMapping("/list")
+	@ApiResponse(content = @Content(schema = @Schema(implementation = Meeting.class)))
+	public Message list() {
+		return Message.success(this.meetingManager.meetings());
+	}
+
+	@Operation(summary = "会议状态", description = "会议状态")
+	@GetMapping("/status/{id}")
+	public Message status(@PathVariable String id) {
+		return Message.success(this.meetingManager.meeting(id));
+	}
+	
+	@Operation(summary = "会议终端列表", description = "会议终端列表")
+	@GetMapping("/list/client/{id}")
+	public Message listClient(@PathVariable String id) {
+		return Message.success(this.meetingManager.sns(id));
+	}
+	
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/listener/MeetingCreateListener.java

@@ -0,0 +1,27 @@
+package com.acgist.taoyao.media.meeting.listener;
+
+import java.util.Map;
+
+import com.acgist.taoyao.boot.annotation.EventListener;
+import com.acgist.taoyao.boot.model.Message;
+import com.acgist.taoyao.media.meeting.Meeting;
+import com.acgist.taoyao.media.meeting.MeetingListenerAdapter;
+import com.acgist.taoyao.signal.event.meeting.MeetingCreateEvent;
+
+/**
+ * 创建会议监听
+ * 
+ * @author acgist
+ */
+@EventListener
+public class MeetingCreateListener extends MeetingListenerAdapter<MeetingCreateEvent> {
+
+	@Override
+	public void onApplicationEvent(MeetingCreateEvent event) {
+		final Meeting meeting = this.meetingManager.create(event.getSn());
+		final Message message = event.getMessage();
+		message.setBody(Map.of("id", meeting.getId()));
+		this.clientSessionManager.broadcast(message);
+	}
+
+}

taoyao-signal/taoyao-media/src/main/java/com/acgist/taoyao/media/meeting/listener/MeetingEnterListener.java

@@ -0,0 +1,41 @@
+package com.acgist.taoyao.media.meeting.listener;
+
+import java.util.Map;
+
+import com.acgist.taoyao.boot.annotation.EventListener;
+import com.acgist.taoyao.boot.model.Message;
+import com.acgist.taoyao.boot.model.MessageCode;
+import com.acgist.taoyao.boot.model.MessageCodeException;
+import com.acgist.taoyao.media.meeting.Meeting;
+import com.acgist.taoyao.media.meeting.MeetingListenerAdapter;
+import com.acgist.taoyao.signal.event.meeting.MeetingEnterEvent;
+
+/**
+ * 进入会议监听
+ * 
+ * @author acgist
+ */
+@EventListener
+public class MeetingEnterListener extends MeetingListenerAdapter<MeetingEnterEvent> {
+
+	@Override
+	public void onApplicationEvent(MeetingEnterEvent event) {
+		final String sn = event.getSn();
+		final String id = event.get("id");
+		final Meeting meeting = this.meetingManager.meeting(id);
+		if(meeting == null) {
+			throw MessageCodeException.of(MessageCode.CODE_3400, "无效会议");
+		}
+		meeting.addSn(sn);
+		final Message message = event.getMessage();
+		message.setBody(Map.of(
+			"id", meeting.getId(),
+			"sn", sn
+		));
+		// TODO：返回房间列表
+		meeting.getSns().stream()
+		.filter(v -> !sn.equals(v))
+		.forEach(v -> this.clientSessionManager.unicast(v, message));
+	}
+
+}