尚硅谷大数据技术之HBase

2018-12-13 本文已影响71人尚硅谷教育

8.2.8 移除（取关）用户
a、在微博用户关系表中，对当前主动操作的用户移除取关的好友(attends)
b、在微博用户关系表中，对被取关的用户移除粉丝
c、微博收件箱中删除取关的用户发布的微博
代码：public void removeAttends(String uid, String... attends)
/**

取消关注（remove)
a、在微博用户关系表中，对当前主动操作的用户删除对应取关的好友
b、在微博用户关系表中，对被取消关注的人删除粉丝（当前操作人）

c、从收件箱中，删除取关的人的微博的rowkey
*/
public void removeAttends(String uid, String... attends){
//过滤数据
if(uid == null || uid.length() <= 0 || attends == null || attends.length <= 0) return;
HConnection connection = null;

try {
connection = HConnectionManager.createConnection(conf);
//a、在微博用户关系表中，删除已关注的好友
HTableInterface relationsTBL = connection.getTable(TableName.valueOf(TABLE_RELATIONS));

 //待删除的用户关系表中的所有数据
 List<Delete> deletes = new ArrayList<Delete>();
 //当前取关操作者的uid对应的Delete对象
 Delete attendDelete = new Delete(Bytes.toBytes(uid));
 //遍历取关，同时每次取关都要将被取关的人的粉丝-1
 for(String attend : attends){
     attendDelete.deleteColumn(Bytes.toBytes("attends"), Bytes.toBytes(attend));
     //b
     Delete fansDelete = new Delete(Bytes.toBytes(attend));
     fansDelete.deleteColumn(Bytes.toBytes("fans"), Bytes.toBytes(uid));
     deletes.add(fansDelete);
 }
 
 deletes.add(attendDelete);
 relationsTBL.delete(deletes);
 
 //c、删除取关的人的微博rowkey 从 收件箱表中
 HTableInterface recTBL = connection.getTable(TableName.valueOf(TABLE_RECEIVE_CONTENT_EMAIL));
 
 Delete recDelete = new Delete(Bytes.toBytes(uid));
 for(String attend : attends){
     recDelete.deleteColumn(Bytes.toBytes("info"), Bytes.toBytes(attend));
 }
 recTBL.delete(recDelete);

} catch (IOException e) {
e.printStackTrace();
}
}
8.2.9 获取关注的人的微博内容
a、从微博收件箱中获取所关注的用户的微博RowKey
b、根据获取的RowKey，得到微博内容
代码实现：public List<Message> getAttendsContent(String uid)
/**

获取微博实际内容
a、从微博收件箱中获取所有关注的人的发布的微博的rowkey
b、根据得到的rowkey去微博内容表中得到数据
c、将得到的数据封装到Message对象中
*/
public List<Message> getAttendsContent(String uid){
HConnection connection = null;
try {
connection = HConnectionManager.createConnection(conf);
HTableInterface recTBL = connection.getTable(TableName.valueOf(TABLE_RECEIVE_CONTENT_EMAIL));
//a、从收件箱中取得微博rowKey
Get get = new Get(Bytes.toBytes(uid));
//设置最大版本号
get.setMaxVersions(5);
List<byte[]> rowkeys = new ArrayList<byte[]>();
Result result = recTBL.get(get);
for(Cell cell : result.rawCells()){
rowkeys.add(CellUtil.cloneValue(cell));
}
//b、根据取出的所有rowkey去微博内容表中检索数据
HTableInterface contentTBL = connection.getTable(TableName.valueOf(TABLE_CONTENT));
List<Get> gets = new ArrayList<Get>();
//根据rowkey取出对应微博的具体内容
for(byte[] rk : rowkeys){
Get g = new Get(rk);
gets.add(g);
}
//得到所有的微博内容的result对象
Result[] results = contentTBL.get(gets);
```
 List<Message> messages = new ArrayList<Message>();
 for(Result res : results){
     for(Cell cell : res.rawCells()){
         Message message = new Message();
         
         String rowKey = Bytes.toString(CellUtil.cloneRow(cell));
         String userid = rowKey.substring(0, rowKey.indexOf("_"));
         String timestamp = rowKey.substring(rowKey.indexOf("_") + 1);
         String content = Bytes.toString(CellUtil.cloneValue(cell));
         
         message.setContent(content);
         message.setTimestamp(timestamp);
         message.setUid(userid);
         
         messages.add(message);
     }
 }
 return messages;
```
} catch (IOException e) {
e.printStackTrace();
}finally{
try {
connection.close();
} catch (IOException e) {
e.printStackTrace();
}
}
return null;
}

本教程由尚硅谷教育大数据研究院出品，如需转载请注明来源，欢迎大家关注尚硅谷公众号（atguigu）了解更多。

尚硅谷大数据技术之HBase

猜你喜欢

热点阅读