HBase项目之谷粒微博:创建命名空间,微博内容表,用户关系表,微博收件箱表,发布微博内容,添加关注用户,移除（取关）用户,获取关注的人的微博内容,HBase实战项目
2024-04-04 07:02:42
Hbase实战之谷粒微博
1 需求分析
1) 微博内容的浏览，数据库表设计
2) 用户社交体现：关注用户，取关用户
3) 拉取关注的人的微博内容
2 代码实现
2.1 代码设计总览：
1) 创建命名空间以及表名的定义
2) 创建微博内容表
3) 创建用户关系表
4) 创建用户微博内容接收邮件表
5) 发布微博内容
6) 添加关注用户
7) 移除（取关）用户
8) 获取关注的人的微博内容
9) 测试
数据库关系表
2.2 创建命名空间以及表名的定义
//获取配置conf
private Configuration conf = HBaseConfiguration.create();//微博内容表的表名
private static final byte[] TABLE_CONTENT = Bytes.toBytes("weibo:content");
//用户关系表的表名
private static final byte[] TABLE_RELATIONS = Bytes.toBytes("weibo:relations");
//微博收件箱表的表名
private static final byte[] TABLE_RECEIVE_CONTENT_EMAIL = Bytes.toBytes("weibo:receive_content_email");
public void initNamespace(){HBaseAdmin admin = null;try {admin = new HBaseAdmin(conf);//命名空间类似于关系型数据库中的schema，可以想象成文件夹NamespaceDescriptor weibo = NamespaceDescriptor.create("weibo").addConfiguration("creator", "Jinji").addConfiguration("create_time", System.currentTimeMillis() + "").build();admin.createNamespace(weibo);} catch (MasterNotRunningException e) {e.printStackTrace();} catch (ZooKeeperConnectionException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally{if(null != admin){try {admin.close();} catch (IOException e) {e.printStackTrace();}}}
}
2.3 创建微博内容表
表结构：
|
方法名 |
creatTableeContent |
|
Table Name |
weibo:content |
|
RowKey |
用户ID_时间戳 |
|
ColumnFamily |
info |
|
ColumnLabel |
标题,内容,图片 |
|
Version |
1个版本 |
代码：
/*** 创建微博内容表* Table Name:weibo:content* RowKey:用户ID_时间戳* ColumnFamily:info* ColumnLabel:标题 内容 图片URL* Version:1个版本*/
public void createTableContent(){HBaseAdmin admin = null;try {admin = new HBaseAdmin(conf);//创建表表述HTableDescriptor content = new HTableDescriptor(TableName.valueOf(TABLE_CONTENT));//创建列族描述HColumnDescriptor info = new HColumnDescriptor(Bytes.toBytes("info"));//设置块缓存info.setBlockCacheEnabled(true);//设置块缓存大小info.setBlocksize(2097152);//设置压缩方式
// info.setCompressionType(Algorithm.SNAPPY);//设置版本确界info.setMaxVersions(1);info.setMinVersions(1);content.addFamily(info);admin.createTable(content);} catch (MasterNotRunningException e) {e.printStackTrace();} catch (ZooKeeperConnectionException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally{if(null != admin){try {admin.close();} catch (IOException e) {e.printStackTrace();}}}
}2.4 创建用户关系表
表结构：
|
方法名 |
createTableRelations |
|
Table Name |
weibo:relations |
|
RowKey |
用户ID |
|
ColumnFamily |
attends、fans |
|
ColumnLabel |
关注用户ID，粉丝用户ID |
|
ColumnValue |
用户ID |
|
Version |
1个版本 |
代码：
/*** 用户关系表* Table Name:weibo:relations* RowKey:用户ID* ColumnFamily:attends,fans* ColumnLabel:关注用户ID，粉丝用户ID* ColumnValue:用户ID* Version：1个版本*/
public void createTableRelations(){HBaseAdmin admin = null;try {admin = new HBaseAdmin(conf);HTableDescriptor relations = new HTableDescriptor(TableName.valueOf(TABLE_RELATIONS));//关注的人的列族HColumnDescriptor attends = new HColumnDescriptor(Bytes.toBytes("attends"));//设置块缓存attends.setBlockCacheEnabled(true);//设置块缓存大小attends.setBlocksize(2097152);//设置压缩方式
// info.setCompressionType(Algorithm.SNAPPY);//设置版本确界attends.setMaxVersions(1);attends.setMinVersions(1);//粉丝列族HColumnDescriptor fans = new HColumnDescriptor(Bytes.toBytes("fans"));fans.setBlockCacheEnabled(true);fans.setBlocksize(2097152);fans.setMaxVersions(1);fans.setMinVersions(1);relations.addFamily(attends);relations.addFamily(fans);admin.createTable(relations);} catch (MasterNotRunningException e) {e.printStackTrace();} catch (ZooKeeperConnectionException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally{if(null != admin){try {admin.close();} catch (IOException e) {e.printStackTrace();}}}
}2.5 创建微博收件箱表
表结构：
|
方法名 |
createTableReceiveContentEmails |
|
Table Name |
weibo:receive_content_email |
|
RowKey |
用户ID |
|
ColumnFamily |
info |
|
ColumnLabel |
用户ID |
|
ColumnValue |
取微博内容的RowKey |
|
Version |
1000 |
代码：
/*** 创建微博收件箱表* Table Name: weibo:receive_content_email* RowKey:用户ID* ColumnFamily:info* ColumnLabel:用户ID-发布微博的人的用户ID* ColumnValue:关注的人的微博的RowKey* Version:1000*/
public void createTableReceiveContentEmail(){HBaseAdmin admin = null;try {admin = new HBaseAdmin(conf);HTableDescriptor receive_content_email = new HTableDescriptor(TableName.valueOf(TABLE_RECEIVE_CONTENT_EMAIL));HColumnDescriptor info = new HColumnDescriptor(Bytes.toBytes("info"));info.setBlockCacheEnabled(true);info.setBlocksize(2097152);info.setMaxVersions(1000);info.setMinVersions(1000);receive_content_email.addFamily(info);;admin.createTable(receive_content_email);} catch (MasterNotRunningException e) {e.printStackTrace();} catch (ZooKeeperConnectionException e) {e.printStackTrace();} catch (IOException e) {e.printStackTrace();}finally{if(null != admin){try {admin.close();} catch (IOException e) {e.printStackTrace();}}}
}2.6 发布微博内容
a、微博内容表中添加1条数据
b、微博收件箱表对所有粉丝用户添加数据
代码：Message.java
public class Message {private String uid;private String timestamp;private String content;public String getUid() {return uid;}public void setUid(String uid) {this.uid = uid;}public String getTimestamp() {return timestamp;}public void setTimestamp(String timestamp) {this.timestamp = timestamp;}public String getContent() {return content;}public void setContent(String content) {this.content = content;}@Overridepublic String toString() {return "Message [uid=" + uid + ", timestamp=" + timestamp + ", content=" + content + "]";}
}代码：public void publishContent(String uid, String content)
/*** 发布微博* a、微博内容表中数据+1* b、向微博收件箱表中加入微博的Rowkey*/
public void publishContent(String uid, String content){HConnection connection = null;try {connection = HConnectionManager.createConnection(conf);//a、微博内容表中添加1条数据，首先获取微博内容表描述HTableInterface contentTBL = connection.getTable(TableName.valueOf(TABLE_CONTENT));//组装Rowkeylong timestamp = System.currentTimeMillis();String rowKey = uid + "_" + timestamp;Put put = new Put(Bytes.toBytes(rowKey));put.add(Bytes.toBytes("info"), Bytes.toBytes("content"), timestamp, Bytes.toBytes(content));contentTBL.put(put);//b、向微博收件箱表中加入发布的Rowkey//b.1、查询用户关系表，得到当前用户有哪些粉丝HTableInterface relationsTBL = connection.getTable(TableName.valueOf(TABLE_RELATIONS));//b.2、取出目标数据Get get = new Get(Bytes.toBytes(uid));get.addFamily(Bytes.toBytes("fans"));Result result = relationsTBL.get(get);List<byte[]> fans = new ArrayList<byte[]>();//遍历取出当前发布微博的用户的所有粉丝数据for(Cell cell : result.rawCells()){fans.add(CellUtil.cloneQualifier(cell));}//如果该用户没有粉丝，则直接returnif(fans.size() <= 0) return;//开始操作收件箱表HTableInterface recTBL = connection.getTable(TableName.valueOf(TABLE_RECEIVE_CONTENT_EMAIL));List<Put> puts = new ArrayList<Put>();for(byte[] fan : fans){Put fanPut = new Put(fan);fanPut.add(Bytes.toBytes("info"), Bytes.toBytes(uid), timestamp, Bytes.toBytes(rowKey));puts.add(fanPut);}recTBL.put(puts);} catch (IOException e) {e.printStackTrace();}finally{if(null != connection){try {connection.close();} catch (IOException e) {e.printStackTrace();}}}
}2.7 添加关注用户
a、在微博用户关系表中，对当前主动操作的用户添加新关注的好友
b、在微博用户关系表中，对被关注的用户添加新的粉丝
c、微博收件箱表中添加所关注的用户发布的微博
代码实现：public void addAttends(String uid, String... attends)
/*** 关注用户逻辑* a、在微博用户关系表中，对当前主动操作的用户添加新的关注的好友* b、在微博用户关系表中，对被关注的用户添加粉丝（当前操作的用户）* c、当前操作用户的微博收件箱添加所关注的用户发布的微博rowkey*/
public void addAttends(String uid, String... attends){//参数过滤if(attends == null || attends.length <= 0 || uid == null || uid.length() <= 0){return;}HConnection connection = null;try {connection = HConnectionManager.createConnection(conf);//用户关系表操作对象（连接到用户关系表）HTableInterface relationsTBL = connection.getTable(TableName.valueOf(TABLE_RELATIONS));List<Put> puts = new ArrayList<Put>();//a、在微博用户关系表中，添加新关注的好友Put attendPut = new Put(Bytes.toBytes(uid));for(String attend : attends){//为当前用户添加关注的人attendPut.add(Bytes.toBytes("attends"), Bytes.toBytes(attend), Bytes.toBytes(attend));//b、为被关注的人，添加粉丝Put fansPut = new Put(Bytes.toBytes(attend));fansPut.add(Bytes.toBytes("fans"), Bytes.toBytes(uid), Bytes.toBytes(uid));//将所有关注的人一个一个的添加到puts（List）集合中puts.add(fansPut);}puts.add(attendPut);relationsTBL.put(puts);//c.1、微博收件箱添加关注的用户发布的微博内容（content）的rowkeyHTableInterface contentTBL = connection.getTable(TableName.valueOf(TABLE_CONTENT));Scan scan = new Scan();//用于存放取出来的关注的人所发布的微博的rowkeyList<byte[]> rowkeys = new ArrayList<byte[]>();for(String attend : attends){//过滤扫描rowkey，即：前置位匹配被关注的人的uid_RowFilter filter = new RowFilter(CompareFilter.CompareOp.EQUAL, new SubstringComparator(attend + "_"));//为扫描对象指定过滤规则scan.setFilter(filter);//通过扫描对象得到scannerResultScanner result = contentTBL.getScanner(scan);//迭代器遍历扫描出来的结果集Iterator<Result> iterator = result.iterator();while(iterator.hasNext()){//取出每一个符合扫描结果的那一行数据Result r = iterator.next();for(Cell cell : r.rawCells()){//将得到的rowkey放置于集合容器中rowkeys.add(CellUtil.cloneRow(cell));}}}//c.2、将取出的微博rowkey放置于当前操作用户的收件箱中if(rowkeys.size() <= 0) return;//得到微博收件箱表的操作对象HTableInterface recTBL = connection.getTable(TableName.valueOf(TABLE_RECEIVE_CONTENT_EMAIL));//用于存放多个关注的用户的发布的多条微博rowkey信息List<Put> recPuts = new ArrayList<Put>();for(byte[] rk : rowkeys){Put put = new Put(Bytes.toBytes(uid));//uid_timestampString rowKey = Bytes.toString(rk);//借取uidString attendUID = rowKey.substring(0, rowKey.indexOf("_"));long timestamp = Long.parseLong(rowKey.substring(rowKey.indexOf("_") + 1));//将微博rowkey添加到指定单元格中put.add(Bytes.toBytes("info"), Bytes.toBytes(attendUID), timestamp, rk);recPuts.add(put);}recTBL.put(recPuts);} catch (IOException e) {e.printStackTrace();}finally{if(null != connection){try {connection.close();} catch (IOException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}
}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));//遍历取关，同时每次取关都要将被取关的人的粉丝-1for(String attend : attends){attendDelete.deleteColumn(Bytes.toBytes("attends"), Bytes.toBytes(attend));//bDelete 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();}
}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、从收件箱中取得微博rowKeyGet 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;
}8.2.10 测试
-- 测试发布微博内容
public void testPublishContent(WeiBo wb)
-- 测试添加关注
public void testAddAttend(WeiBo wb)
-- 测试取消关注
public void testRemoveAttend(WeiBo wb)
-- 测试展示内容
public void testShowMessage(WeiBo wb)
代码：
/*** 发布微博内容* 添加关注* 取消关注* 展示内容*/
public void testPublishContent(WeiBo wb){wb.publishContent("0001", "今天买了一包空气，送了点薯片，非常开心！！");wb.publishContent("0001", "今天天气不错。");
}public void testAddAttend(WeiBo wb){wb.publishContent("0008", "准备下课！");wb.publishContent("0009", "准备关机！");wb.addAttends("0001", "0008", "0009");
}public void testRemoveAttend(WeiBo wb){wb.removeAttends("0001", "0008");
}public void testShowMessage(WeiBo wb){List<Message> messages = wb.getAttendsContent("0001");for(Message message : messages){System.out.println(message);}
}public static void main(String[] args) {WeiBo weibo = new WeiBo();weibo.initTable();weibo.testPublishContent(weibo);weibo.testAddAttend(weibo);weibo.testShowMessage(weibo);weibo.testRemoveAttend(weibo);weibo.testShowMessage(weibo);
}全部代码笔记:
固定命名类Contants:
public class Contants {//命名空间public static final String NAME_SPACE = "weibo";//用户关系表public static final String RELATION_TABLE = NAME_SPACE + ":relation";//微博内容表public static final String CONTENT_TABLE = NAME_SPACE + ":content";//收件箱表public static final String INBOX_TABLE = NAME_SPACE + ":inbox";
}
业务工具类:WeiBoUtil:
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter.RowFilter;
import org.apache.hadoop.hbase.filter.SubstringComparator;
import org.apache.hadoop.hbase.util.Bytes;import java.io.IOException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.Date;public class WeiBoUtil {//获取hbase配置信息private static Configuration configuration = HBaseConfiguration.create();static {configuration.set("hbase.zookeeper.quorum", "192.168.9.102");}/*** 创建命名空间*/public static void createNamespace(String ns) throws IOException {//获取hbase管理员对象Connection connection = ConnectionFactory.createConnection(configuration);Admin admin = connection.getAdmin();//构建命名空间描述器NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create(ns).build();//创建namespaceadmin.createNamespace(namespaceDescriptor);admin.close();connection.close();}/*** 创建表*/public static void createTable(String tableName, int versions, String... cfs) throws IOException {//获取hbase管理员对象Connection connection = ConnectionFactory.createConnection(configuration);Admin admin = connection.getAdmin();HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));for (String cf : cfs) {HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(cf);hColumnDescriptor.setMaxVersions(versions);hTableDescriptor.addFamily(hColumnDescriptor);}admin.createTable(hTableDescriptor);admin.close();connection.close();}public static void putData(String tableName, String uid, String cf, String cn, String value) throws IOException {Connection connection = ConnectionFactory.createConnection(configuration);Table table = connection.getTable(TableName.valueOf(tableName));//封装putlong ts = System.currentTimeMillis();String rowkey = uid + "_" + ts;Put put = new Put(Bytes.toBytes(rowkey));put.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn), ts, Bytes.toBytes(value));//执行操作table.put(put);//更新收件箱表Table inboxTable = connection.getTable(TableName.valueOf(Contants.INBOX_TABLE));Table relationTable = connection.getTable(TableName.valueOf(Contants.RELATION_TABLE));Get get = new Get(Bytes.toBytes(uid));Result result = relationTable.get(get);ArrayList<Put> puts = new ArrayList<>();for (Cell cell : result.rawCells()) {if ("fans".equals(Bytes.toString(CellUtil.cloneFamily(cell)))) {byte[] inboxRowkey = CellUtil.cloneQualifier(cell);Put inboxPut = new Put(inboxRowkey);inboxPut.addColumn(Bytes.toBytes("info"), Bytes.toBytes(uid), ts, Bytes.toBytes(rowkey));puts.add(inboxPut);}}inboxTable.put(puts);table.close();inboxTable.close();connection.close();}/*** 添加关注用户（多个）* 1.在用户关系表中，给当前用户添加attends* 2.在用户关系表中，给被关注用户添加fans* 3.在收件箱表中，给当前用户添加关注用户最近所发微博的rowkey*/public static void addAttends(String uid, String... attends) throws IOException {//1.在用户关系表中，给当前用户添加attendsConnection connection = ConnectionFactory.createConnection(configuration);Table table = connection.getTable(TableName.valueOf(Contants.RELATION_TABLE));Put attendPut = new Put(Bytes.toBytes(uid));//存放被关注用户的添加对象ArrayList<Put> puts = new ArrayList<>();puts.add(attendPut);for (String attend : attends) {attendPut.addColumn(Bytes.toBytes("attends"), Bytes.toBytes(attend), Bytes.toBytes(""));//2.在用户关系表中，给被关注用户添加fansPut put = new Put(Bytes.toBytes(attend));put.addColumn(Bytes.toBytes("fans"), Bytes.toBytes(uid), Bytes.toBytes(""));puts.add(put);}table.put(puts);//3.在收件箱表中，给当前用户添加关注用户最近所发微博的rowkeyTable inboxTabel = connection.getTable(TableName.valueOf(Contants.INBOX_TABLE));Table contentTable = connection.getTable(TableName.valueOf(Contants.CONTENT_TABLE));Put inboxPut = new Put(Bytes.toBytes(uid));if (attends.length <= 0) {return;}//循环添加要增加的数据for (String attend : attends) {//通过startRow和stopRow构建扫描器
// Scan scan = new Scan(Bytes.toBytes(attend), Bytes.toBytes(attend + "|"));//通过过滤器构建扫描器Scan scan = new Scan();RowFilter rowFilter = new RowFilter(CompareFilter.CompareOp.EQUAL, new SubstringComparator(attend + "_"));scan.setFilter(rowFilter);//获取所有符合扫描规则的额数据ResultScanner scanner = contentTable.getScanner(scan);//循环遍历取出每条数据的rowkey添加到inboxPut中for (Result result : scanner) {byte[] row = result.getRow();inboxPut.addColumn(Bytes.toBytes("info"), Bytes.toBytes(attend), row);//往收件箱表中给操作者添加数据inboxTabel.put(inboxPut);}}//关闭资源inboxTabel.close();contentTable.close();table.close();connection.close();}/*** 取关* 1.在用户关系表中，删除当前用户的attends* 2.在用户关系表中，删除被取关用户的fans（操作者）* 3.在收件箱表中删除取关用户的所有数据*/public static void deleteRelation(String uid, String... deletes) throws IOException {Connection connection = ConnectionFactory.createConnection(configuration);//获取用户关系表对象Table relationTable = connection.getTable(TableName.valueOf(Contants.RELATION_TABLE));//存放关系表中所有要输出的对象的集合ArrayList<Delete> deleteArrayList = new ArrayList<>();// 1.在用户关系表中，删除当前用户的attendsDelete userDelete = new Delete(Bytes.toBytes(uid));for (String delete : deletes) {//给当前用户添加要删除的列userDelete.addColumn(Bytes.toBytes("attends"), Bytes.toBytes(delete));//2.在用户关系表中，删除被取关用户的fans（操作者）Delete fanDelete = new Delete(Bytes.toBytes(delete));//给被关注这添加删除的列fanDelete.addColumn(Bytes.toBytes("fans"), Bytes.toBytes(uid));deleteArrayList.add(fanDelete);}deleteArrayList.add(userDelete);//用户关系表删除操作relationTable.delete(deleteArrayList);//3.在收件箱表中删除取关用户的所有数据Table inboxTable = connection.getTable(TableName.valueOf(Contants.INBOX_TABLE));Delete inboxDelete = new Delete(Bytes.toBytes(uid));//循环添加要删除内容for (String delete : deletes) {inboxDelete.addColumns(Bytes.toBytes("info"), Bytes.toBytes(delete));}inboxTable.delete(inboxDelete);//关闭资源relationTable.close();inboxTable.close();connection.close();}/*** 获取关注的人的微博内容*/public static void getWeiBo(String uid) throws IOException {//获取微博内容表及收件箱表对象Connection connection = ConnectionFactory.createConnection(configuration);Table inboxTable = connection.getTable(TableName.valueOf(Contants.INBOX_TABLE));Table contentTable = connection.getTable(TableName.valueOf(Contants.CONTENT_TABLE));Get get = new Get(Bytes.toBytes(uid));get.setMaxVersions(3);Result result = inboxTable.get(get);for (Cell cell : result.rawCells()) {byte[] contentRowkey = CellUtil.cloneValue(cell);Get contentGet = new Get(contentRowkey);Result contentResult = contentTable.get(contentGet);for (Cell cell1 : contentResult.rawCells()) {String uid_ts = Bytes.toString(CellUtil.cloneRow(cell1));String id = uid_ts.split("_")[0];String ts = uid_ts.split("_")[1];String date = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(Long.parseLong(ts)));System.out.println("用户：" + id + "，时间" + date + "，内容：" + Bytes.toString(CellUtil.cloneValue(cell1)));}}inboxTable.close();contentTable.close();connection.close();}}
测试主类WeiBo:
import java.io.IOException;public class Weibo {public static void init() throws IOException {WeiBoUtil.createNamespace(Contants.NAME_SPACE);//创建用户关系表WeiBoUtil.createTable(Contants.RELATION_TABLE, 1, "attends", "fans");//创建微博内容表WeiBoUtil.createTable(Contants.CONTENT_TABLE, 1, "info");//创建收件箱表WeiBoUtil.createTable(Contants.INBOX_TABLE, 100, "info");}public static void main(String[] args) throws IOException {
// init();//关注
// WeiBoUtil.addAttends("1001", "1002", "1003");//被关注的人发微博（多个人发微博）
// WeiBoUtil.putData(Contants.CONTENT_TABLE, "1002", "info", "content", "今天天气真晴朗！");
// WeiBoUtil.putData(Contants.CONTENT_TABLE, "1002", "info", "content", "春困秋乏！");
// WeiBoUtil.putData(Contants.CONTENT_TABLE, "1003", "info", "content", "夏打盹！");
// WeiBoUtil.putData(Contants.CONTENT_TABLE, "1001", "info", "content", "冬眠睡不醒！");//获取关注人的微博WeiBoUtil.getWeiBo("1001");//关注已经发过微博的人
// WeiBoUtil.addAttends("1002", "1001");//获取关注人的微博
// WeiBoUtil.getWeiBo("1002");//取消关注WeiBoUtil.deleteRelation("1001","1002");//获取关注人的微博WeiBoUtil.getWeiBo("1001");}
}运行获取关注人的微博
关注已发微博的人并获取其发布的微博:
HBase项目之谷粒微博:创建命名空间,微博内容表,用户关系表,微博收件箱表,发布微博内容,添加关注用户,移除（取关）用户,获取关注的人的微博内容,HBase实战项目相关推荐
- Redis实现微博好友功能微服务（关注，取关，共同关注）
点击关注公众号,利用碎片时间学习 需求分析 好友功能是目前社交场景的必备功能之一,一般好友相关的功能包含有:关注/取关.我(他)的关注.我(他)的粉丝.共同关注.我关注的人也关注他等这样一些功能. 类 ...
- Redis实战 - 05 Redis 实现好友功能（关注，取关，共同关注）
文章目录 1. 环境搭建 1. 需求分析 2. 设计思路 3. 数据库表结构 4. 创建子模块 ms-follow 服务 5. 配置类 RedisTemplateConfiguration 6. 配置 ...
- android短信显示内容,Android获取手机短信SMS收件箱内容
Android中读取的短信方式(短信区域),具体有如下几种方式: /** * 所有的短信 */ public static final String SMS_URI_ALL = "conte ...
- （详细总结）python爬取 163收件箱邮件内容，收件箱列表的几种方法(urllib, requests, selenium)
需求:最近有一个需求,需要将163邮箱收件箱里面的所有邮件的内容全部copy下来,整理到一个word里面,不多也就28页的邮件(不要问我为什么有这需求,不告诉你),自己手动去ctrl+ cv 的话,估 ...
- 使用selenium模拟动态登录QQ邮箱爬取收件箱内容放在CSV文件中
获取收件箱列表信息就是使用selenium实现模拟登录.点击收件箱链接.获取收件箱列表的html过程,然后就是正常的查找数据 1.我们首先就是要登录到QQ邮箱中,然后找到收件箱的页面的,才能爬取到 ...
- 收件箱java项目源码,Java物资管理系统项目源码(含数据库).zip
.mymetadata , 279 .project , 1408 │╠╨≥╩╣╙├╦╡├≈.doc , 99840 .settings/.jsdtscope , 500 .settings/org. ...
- checkbox取值 php_php获取checkbox复选框的内容
由于checkbox属性,所有必须把checkbox复选择框的名字设置为一个如果checkbox[],php才能读取,以数据形式,否则不能正确的读取checkbox复选框的值哦. 复选二 复选三 复选 ...
- foxmail收件箱按照每个人进行划分
当我们想把收件箱按照发件人的不同,而进行划分时,可以在收到的邮件右键,然后选择新建一个过滤器. 可以设置满足相应的条件放到相应的文件夹中.这样看起来比较方便吧.
- 菜鸟进阶高手， 推荐 7 个 Python 上手实战项目
作为一个语法简洁.有着丰富的第三方库的编程语言,Python 上手极为简单,短时间内就可以让你编写出能够解决实际问题的小程序,甚至去面试初级 Python 工程师的职位. 不过,如果要写出一些更复杂的 ...
最新文章
- 增加了一行代码，让我们提高了3000%的性能
- SAP Analytics Cloud连接Cloud for Customer的一些后台调试
- cnil在python_在Python中匹配组
- 使用RedisTemplate实现Redis分布式锁出现的一些列问题（避坑）
- python函数定义及调用-python函数基础（函数的定义和调用）
- CF113D 高斯消元、dp
- arcgis将一个shp图层导出为多个shp
- 创建phpinfo.php
- 编程的一些小知识点总结
- 以写代学：python 元组
- Atitit 持久化与数据存储标准化规范 目录 1. 存储的附加功能 2 1.1. 基本存取功能 2 1.2. 全文检索(imap 2 1.3. 属性检索 2 1.4. 查询语言 2 2. 基于内容
- 微信小程序开发之——WebView
- silvaco-mobility models(1)
- Routeros花生壳域名解析脚本
- 做软件产品有哪种商业模式？
- 电脑桌面云便签怎么通过便签快捷键锁屏加密？
- JLink的RTT调试
- linux挂载移动硬盘 格式化_Linux(CentOS)挂载NTFS格式的U盘、移动硬盘
- c语言输入一元二次方程三个系数,C语言程序 一元二次方程
- 云计算未来是什么样子？