交友项目【集成环信Api】

刺骨的言语ヽ痛彻心扉 2023-10-10 18:21 157阅读 0赞

**目录**

1：自动装配

2：查询用户环信账户

3：环信ID查询用户信息

--------------------

#### 1：自动装配 ####

在项目中集成环信API，完成即时通信等

环信官方文档地址：[Java Server SDK \[IM 开发文档\]][Java Server SDK _IM]

![406d7f11c4ad499bbc84da3c6c426c84.png][]

自动装配模块：

![418986b47d7d4bf09db7e9122e1abb61.png][]

pom文件相关依赖

<dependency>
        <groupId>com.easemob.im</groupId>
        <artifactId>im-sdk-core</artifactId>
        <version>0.5.2</version>
    </dependency>

yml文件中配置相关信息

>     huanxin:
>       appkey: ****************
>       clientId: ****************
>       clientSecret: ****************

读取yml文件中的配置

@ConfigurationProperties(prefix = "tanhua.huanxin")
    @Data
    public class HuanXinProperties {
    
        private String appkey;
        private String clientId;
        private String clientSecret;
    
    }

创建封装类以及需要用到的方法

package com.czxy.tanhua.autoconfig.template;
    
    import cn.hutool.core.collection.CollUtil;
    import com.alibaba.fastjson.JSON;
    import com.czxy.tanhua.autoconfig.properties.HuanXinProperties;
    import com.czxy.tanhua.autoconfig.vo.HuanxinMessageVo;
    import com.easemob.im.server.EMProperties;
    import com.easemob.im.server.EMService;
    import com.easemob.im.server.model.EMTextMessage;
    import lombok.extern.log4j.Log4j;
    
    import java.util.Set;
    
    @Log4j
    public class HuanXinTemplate {
        private EMService service;
    
        public HuanXinTemplate(HuanXinProperties properties) {
            EMProperties emProperties = EMProperties.builder()
                    .setAppkey(properties.getAppkey())
                    .setClientId(properties.getClientId())
                    .setClientSecret(properties.getClientSecret())
                    .build();
            service = new EMService(emProperties);
        }
    
        /**
         * 创建环信用户
         * @param username
         * @param password
         * @return
         */
        public Boolean createUser(String username,String password) {
            try {
                //创建环信用户
                service.user().create(username.toLowerCase(), password)
                        .block();
                return true;
            }catch (Exception e) {
                e.printStackTrace();
                log.error("创建环信用户失败~");
            }
            return false;
        }
    
        /**
         * 添加联系人
         * @param username1
         * @param username2
         * @return
         */
        public Boolean addContact(String username1,String username2) {
            try {
                //创建环信用户
                service.contact().add(username1,username2)
                        .block();
                return true;
            }catch (Exception e) {
                log.error("添加联系人失败~");
            }
            return false;
        }
    
        /**
         * 删除联系人
         * @param username1
         * @param username2
         * @return
         */
        public Boolean deleteContact(String username1,String username2) {
            try {
                //创建环信用户
                service.contact().remove(username1,username2)
                        .block();
                return true;
            }catch (Exception e) {
                log.error("删除联系人失败~");
            }
            return false;
        }
    
        /**
         * 发送消息
         * @param username
         * @param huanxinMessageVo
         * @return
         */
        public Boolean sendMsg(String username, HuanxinMessageVo huanxinMessageVo) {
            try {
                //接收人用户列表
                Set<String> set = CollUtil.newHashSet(username);
                // 将消息内容转换成json
                String content = JSON.toJSONString(huanxinMessageVo);
                //文本消息
                EMTextMessage message = new EMTextMessage().text(content);
                //发送消息  from：admin是管理员发送
                service.message().send("admin","users",
                        set,message,null).block();
                return true;
            }catch (Exception e) {
                log.error("删除联系人失败~");
            }
            return false;
        }
    }

在引导类中进行声明封装类，将相关的工具类交给IOC容器管理

/** 自动装配类
     * @description
     */
    @EnableConfigurationProperties({
            SmsProperties.class,
            OssProperties.class,
            AipFaceProperties.class,
            HuanXinProperties.class
    })
    public class TanhuaAutoConfiguration {
    
        @Bean
        public SmsTemplate smsTemplate(SmsProperties smsProperties) {
            return new SmsTemplate(smsProperties);
        }
    
        @Bean
        public OssTemplate ossTemplate(OssProperties ossProperties) {
            return new OssTemplate(ossProperties);
        }
    
        @Bean
        public AipFaceTemplate aipFaceTemplate() {
            return new AipFaceTemplate();
        }
    
        @Bean
        public HuanXinTemplate huanXinTemplate(HuanXinProperties properties) {
            return new HuanXinTemplate(properties);
        }
    }

在resources目录下创建META-INF文件夹，在此文件夹下创建spring.factories文件，该文件声明引导类位置，springboot启动时会加载该文件中声明的引导类完成工具类的自动装配。

org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
      com.czxy.tanhua.autoconfig.TanhuaAutoConfiguration

#### 2：查询用户环信账户 ####

接口地址： http://192.168.136.160:3000/project/19/interface/api/85

![1c7381f148c24da6ad025d9e2ad36315.png][]

app-server模块：

controller层：

@RestController
    @RequestMapping("/huanxin")
    public class HuanxinController {
    
        @Resource
        private UserService userService;
    
        @GetMapping("/user")
        public ResponseEntity<HuanXinUserVo> user() {
            HuanXinUserVo huanXinUserVo = userService.findHuanXinUser();
            return ResponseEntity.ok(huanXinUserVo);
        }
    }

service层：

public HuanXinUserVo findHuanXinUser() {
            // 查询
            User user = userApi.findById(UserHolder.getUserId());
            if(user == null) {
                return null;
            }
            // 封装
            return new HuanXinUserVo(user.getHxUser() ,user.getHxPassword());
        }

#### 3：环信ID查询用户信息 ####

![1a6d4c613aa14423852a6397a8744b0f.png][]

app-server模块：

controller层

@GetMapping("/userinfo")
        public ResponseEntity userinfo(String huanxinId) {
            //查询
            UserInfoVo userInfoVo = messageService.findUserInfoByHuanxin(huanxinId);
            //返回
            return ResponseEntity.ok(userInfoVo);
        }

service层：

/**
         * 通过环信id查询详情
         * @param huanxinId
         * @return
         */
        public UserInfoVo findUserInfoByHuanxin(String huanxinId) {
            //1 通过huanxinId查询用户信息
            User user = userApi.findByHuanxin(huanxinId);
    
            //2 查询UserInfo信息
            UserInfo userInfo = userInfoApi.findById(user.getId());
    
            //3 封装数据UserInfoVo
            UserInfoVo userInfoVo = new UserInfoVo();
            BeanUtils.copyProperties(userInfo, userInfoVo);
            if(userInfo.getAge() != null){
                userInfoVo.setAge(userInfo.getAge().toString());
            }
            return userInfoVo;
        }

通过huanxinId查询用户信息的接口

@Override
        public User findByHuanxin(String huanxinId) {
            QueryWrapper<User> queryWrapper = new QueryWrapper<>();
            queryWrapper.eq("hx_user", huanxinId);
            return userMapper.selectOne(queryWrapper);
        }

通过userid查询用户的接口

@Override
        public UserInfo findById(Long userInfoId) {
            return userInfoMapper.selectById(userInfoId);
        }

[Java Server SDK _IM]: https://docs-im.easemob.com/im/server/ready/sdk
[406d7f11c4ad499bbc84da3c6c426c84.png]: https://img-blog.csdnimg.cn/406d7f11c4ad499bbc84da3c6c426c84.png
[418986b47d7d4bf09db7e9122e1abb61.png]: https://img-blog.csdnimg.cn/418986b47d7d4bf09db7e9122e1abb61.png
[1c7381f148c24da6ad025d9e2ad36315.png]: https://img-blog.csdnimg.cn/1c7381f148c24da6ad025d9e2ad36315.png
[1a6d4c613aa14423852a6397a8744b0f.png]: https://img-blog.csdnimg.cn/1a6d4c613aa14423852a6397a8744b0f.png