课程设计基于java实现的IM即时通信模块源码+项目说明.zip

package top.paakciu.core; import io.netty.channel.Channel; import top.paakciu.client.listener.ClientEventListener; import top.paakciu.config.IMConfig; import top.paakciu.mbg.model.GroupInfo; import top.paakciu.mbg.model.GroupMsgOffline; import top.paakciu.utils.info.ChannelUser; import top.paakciu.utils.ExtraPacketHelper; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Scanner; import java.util.concurrent.CopyOnWriteArrayList; /** * @author paakciu * @ClassName: test * @date: 2021/3/18 16:27 */ public class test implements ClientEventListener { static final Client CLIENT=Client.defaultClient; // static ChannelUser this_channeluser=null; //static Channel this_channel=null; private void printFail(){System.out.println("发送到服务器失败");} private void printSuccess(){System.out.println("发送到服务器成功");} public static void main(String[] args) { new test().onCreate(); } public void onCreate() { /** * 初始化的方法lisntener里面的方法已经是异步方法了，不需要另外创建线程 * 线程池参数可调节IMconfig文件中的CLIENT_THREAD_POOL_NUM参数 * {@link top.paakciu.config.IMConfig} */ Client.defaultClient.initClienConnection(IMConfig.HOST,IMConfig.PORT).setEventListener(new ClientEventListener() { @Override public void onInitChannel() { //TODO 初始化连接的时候要处理的事情 } @Override public void onConnectSuccess(Channel channel) { //TODO 连接成功后要做的事情 //System.out.println("连接成功s"); //register(); Scanner sc=new Scanner(System.in); System.out.println("请输入登录的账号密码："); String name=sc.nextLine(); String psw=sc.nextLine(); login(name,psw); } @Override public void onConnectFail(int retry) { //TODO 连接失败后要做的事情 } }); } public void register(){ /** * 要注意连接成功之后，才能调用该方法进行注册 * 关于注册事件的回调会在Netty的异步线程中进行，不需要建立线程。 * 链式调用！ */ Client.defaultClient.register("username1","password1") .setSendFailListener(()-> { //TODO 发送服务器失败要做的事 System.out.println("发送至服务器失败"); }) .setSendSuccessListener(()->{ //TODO 发送服务器成功要做的事 System.out.println("发送至服务器成功"); }) .setFailListener(str -> { //TODO 服务器返回结果为失败,str为返回失败的消息 System.out.println(str); }) .setSuccessListener(str -> { //TODO 服务器返回结果为成功,str为返回成功的消息 System.out.println(str); }); } public void login(String username,String password) { Client.defaultClient.login(username,password) .setSendFailListener(()-> { //TODO 发送服务器失败要做的事 System.out.println("发送至服务器失败"); }) .setSendSuccessListener(()->{ //TODO 发送服务器成功要做的事 System.out.println("发送至服务器成功"); }) .setFailListener(str -> { //TODO 服务器返回结果为失败,str为返回失败的原因-如“账号密码校验失败” System.out.println(str); }) .setSuccessListener(channelUser -> { //TODO 服务器返回结果为成功,str为返回成功 channelUser对象，包括惟一标识号id，和账号名 System.out.println(channelUser); System.out.println("id="+channelUser.getUserId()); //监听器 setSendListener(); setCreateGroupListener(); setJoinGroupListener(); setErrorListener(); setQuitGroup(); setGetGroupmemeberslistener(); setGetGroupListListener(); setGroupMessageListener(); setGroupOfflineMessageListener(); ExtraListAdd(); setExtraGroupMessageListener(); setGetInfoAndFriendsListener(); setExtraSingleListener(); new Thread(()->{ Scanner sc = new Scanner(System.in); //聊天模拟 while (true) { System.out.println("1单聊测试，2群聊测试,3加群测试，4退群测试，5建群测试,6登出"); int x=sc.nextInt(); if(x==1){ System.out.println("请输入toid msg："); Long toid = sc.nextLong(); String msg = sc.next(); send(toid,msg); } if(x==2){ System.out.println("请输入toid msg："); Long toid = sc.nextLong(); String msg = sc.next(); sendGroupMessage(toid,msg); } if(x==3){ System.out.println("请输入groupid："); Long groupid = sc.nextLong(); joinGroup(groupid, channelUser.getUserId()); } if(x==4){ System.out.println("请输入groupid："); Long groupid = sc.nextLong(); quitGroup(groupid, channelUser.getUserId()); } if(x==5){ System.out.println("请输入群聊名称："); String GroupName = sc.next(); List<Long> list=new ArrayList<>(); list.add(channelUser.getUserId()); CreateGroup(list,GroupName); } if(x==6){ logout(); } // System.out.println("请输入togroupid msg："); // Long togroupid = sc.nextLong(); // String msg = sc.next(); // sendGroupMessage(togroupid,msg); // System.out.println("请输入任意字符串，测试添加好友"); // Long id1=sc.nextLong(); // Long id2=sc.nextLong(); // deleteFriends(id1,id2); // System.out.println("请输入任意字符串，测试获取好友列表"); // sc.nextLine(); // getAllFriends(channelUser.getUserId()); // System.out.println("请输入任意字符串，测试获取在线好友列表"); // sc.nextLine(); // getOnLineFriends(channelUser.getUserId());